From 7719f065fd04352c0960b993a19d415940ff7dde Mon Sep 17 00:00:00 2001 From: Kaspar Date: Wed, 2 Dec 2020 14:07:22 +0200 Subject: [PATCH] Update ObservationProducer.java There is no topic "temperature_avro2" -> we've created topic "temperature". --- .../java/ee/ut/cs/dsg/dsg/exercise2/ObservationProducer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ksql/src/main/java/ee/ut/cs/dsg/dsg/exercise2/ObservationProducer.java b/ksql/src/main/java/ee/ut/cs/dsg/dsg/exercise2/ObservationProducer.java index 6c631b0..2b58299 100644 --- a/ksql/src/main/java/ee/ut/cs/dsg/dsg/exercise2/ObservationProducer.java +++ b/ksql/src/main/java/ee/ut/cs/dsg/dsg/exercise2/ObservationProducer.java @@ -13,7 +13,7 @@ public class ObservationProducer { - public static String TOPIC = "temperature_avro2"; + public static String TOPIC = "temperature"; public void createProducer() throws InterruptedException { @@ -23,7 +23,7 @@ public void createProducer() throws InterruptedException { props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka1:9092"); props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName()); props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, KafkaAvroSerializer.class.getName()); -// props.put(ProducerConfig.PARTITIONER_CLASS_CONFIG, CustomPartitioner.class.getName()); + props.put(ProducerConfig.PARTITIONER_CLASS_CONFIG, CustomPartitioner.class.getName()); // props.put(KafkaAvroDeserializerConfig.SCHEMA_REGISTRY_URL_CONFIG, "mock://" + scope); props.put(KafkaAvroDeserializerConfig.SCHEMA_REGISTRY_URL_CONFIG, "http://schema-registry:8081/");