From e61d7f8b7e7d40dfa8a07bffdcb0f582d052e8c7 Mon Sep 17 00:00:00 2001
From: Laxman Ch <60599147+laxmanchekka@users.noreply.github.com>
Date: Tue, 15 Sep 2020 13:49:35 +0530
Subject: [PATCH] Kafka streams cofig fix (#25)

---
 helm/templates/span-normalizer-config.yaml                      | 2 --
 .../src/main/resources/configs/common/application.conf          | 1 +
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git a/helm/templates/span-normalizer-config.yaml b/helm/templates/span-normalizer-config.yaml
index c55355639..d8b448e19 100644
--- a/helm/templates/span-normalizer-config.yaml
+++ b/helm/templates/span-normalizer-config.yaml
@@ -10,9 +10,7 @@ data:
       application.id = jaeger-spans-to-raw-spans-job
       metrics.recording.level = "{{ .Values.spanNormalizerConfig.kafka.streams.config.metricsRecordingLevel }}"
       num.stream.threads = "{{ .Values.spanNormalizerConfig.kafka.streams.config.numStreamThreads }}"
-      producer.compression.type = gzip
       producer.max.request.size = 10485760
-      topology.optimization = all
       bootstrap.servers = "{{ .Values.spanNormalizerConfig.kafka.streams.config.bootstrapServers }}"
       auto.offset.reset = "latest"
       auto.commit.interval.ms = 5000
diff --git a/span-normalizer/src/main/resources/configs/common/application.conf b/span-normalizer/src/main/resources/configs/common/application.conf
index 650130922..d7d92878c 100644
--- a/span-normalizer/src/main/resources/configs/common/application.conf
+++ b/span-normalizer/src/main/resources/configs/common/application.conf
@@ -18,6 +18,7 @@ kafka.streams.config = {
 
   schema.registry.url = "http://localhost:8081"
   schema.registry.url = ${?SCHEMA_REGISTRY_URL}
+  value.subject.name.strategy = "io.confluent.kafka.serializers.subject.TopicRecordNameStrategy"
 }
 
 processor {