Kafka streams cofig fix (#25)

hypertrace · Sep 15, 2020 · e61d7f8 · e61d7f8
1 parent e4841cb
commit e61d7f8
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git 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
@@ -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 {