CODEWITHSUNDEEP
apache-kafka-streams
Neeraj Bhatt
Neeraj Bhatt

Reputation: 11

Partition Strategy in Kafka Stream

Which partition strategy Kafka stream uses ? Can we change the partition strategy in Kafka Stream as we can change in normal Kafka Consumer

streamsConfiguration.put(ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG,Collections.singletonList(StickyAssignor.class));

makes no difference and always StreamsPartitionAssignor is used

Upvotes: 0

Views: 1859

Answers (1)

Matthias J. Sax
Matthias J. Sax

Reputation: 62360

No. You cannot set an partition assignor.

Kafka Streams has very specific requirements how partition assignment works and if not done correctly, incorrect result could be computed. Thus, it's not allowed to set a custom partitions assignor.

Upvotes: 1

Related Questions