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/");