Create topics with 2 partitions

It makes more sense with the exemple since we do some repartitionning
Raouf25 · Sep 18, 2020 · 2c2b789 · 2c2b789
1 parent 18cbc86
commit 2c2b789
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 10 deletions.
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -38,11 +38,11 @@ services:
       - broker
     command: "bash -c 'echo Waiting for Kafka to be ready... && \
                        cub kafka-ready -b broker:29092 1 20 && \
-                       kafka-topics --create --if-not-exists --zookeeper zookeeper:2181 --partitions 1 --replication-factor 1 --topic product_details && \
-                       kafka-topics --create --if-not-exists --zookeeper zookeeper:2181 --partitions 1 --replication-factor 1 --topic prices && \
-                       kafka-topics --create --if-not-exists --zookeeper zookeeper:2181 --partitions 1 --replication-factor 1 --topic sku_details && \
-                       kafka-topics --create --if-not-exists --zookeeper zookeeper:2181 --partitions 1 --replication-factor 1 --topic offer_details && \
-                       kafka-topics --create --if-not-exists --zookeeper zookeeper:2181 --partitions 1 --replication-factor 1 --topic products ' "
+                       kafka-topics --create --if-not-exists --zookeeper zookeeper:2181 --partitions 2 --replication-factor 1 --topic product_details && \
+                       kafka-topics --create --if-not-exists --zookeeper zookeeper:2181 --partitions 2 --replication-factor 1 --topic prices && \
+                       kafka-topics --create --if-not-exists --zookeeper zookeeper:2181 --partitions 2 --replication-factor 1 --topic sku_details && \
+                       kafka-topics --create --if-not-exists --zookeeper zookeeper:2181 --partitions 2 --replication-factor 1 --topic offer_details && \
+                       kafka-topics --create --if-not-exists --zookeeper zookeeper:2181 --partitions 2 --replication-factor 1 --topic products ' "
 
   akhq:
     image: tchiotludo/akhq

diff --git a/...ain/java/com/adrienben/demo/kstreamconnectionsaggregationexample/config/StreamConfig.java b/...ain/java/com/adrienben/demo/kstreamconnectionsaggregationexample/config/StreamConfig.java
@@ -21,8 +21,7 @@
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.kafka.annotation.EnableKafkaStreams;
-import org.springframework.kafka.support.serializer.JsonDeserializer;
-import org.springframework.kafka.support.serializer.JsonSerializer;
+import org.springframework.kafka.support.serializer.JsonSerde;
 
 @Slf4j
 @Configuration
@@ -124,8 +123,6 @@ public KStream<String, Product> kStream(StreamsBuilder streamBuilder) {
 	}
 
 	private <T> Serde<T> jsonSerde(Class<T> targetClass) {
-		return Serdes.serdeFrom(
-				new JsonSerializer<>(mapper),
-				new JsonDeserializer<>(targetClass, mapper, false));
+		return new JsonSerde<>(targetClass, mapper).noTypeInfo().ignoreTypeHeaders();
 	}
 }