CODEWITHSUNDEEP
javaapache-kafkaapache-kafka-streams
Konrad
Konrad

Reputation: 23

Kafka streams repartitioning

In Kafka streams when function to modify the key is used then Kafka Streams creates internal repartitioned topic. I wonder what is number of partition of newly created topic? When new topic partition number is grater than 1 then other consumers from consumers group also are involved for consuming that internal topic?

I am trying to scale one of my consumers but I try to understand first how does it works.

Upvotes: 0

Views: 463

Answers (1)

OneCricketeer
OneCricketeer

Reputation: 191681

If you don't set it using Repartitioned.numberOfPartitions(), then it's the same as the input topic.

Reference - Is there a way to repartition the input topic in Kafka streams?

Upvotes: 1

Related Questions