WoW
WoW

Reputation: 3

Are spring.cloud.stream.instanceCount and instanceIndex required if using Kafka and autoRebalanceEnabled is true?

Question 1: Are these 2 properties below required if using Kafka AND autoRebalanceEnabled is true AND multiple of Spring Cloud Stream application instances are launched independently AND spring.cloud.stream.bindings.uppercase-in-0.consumer.partitioned=true?

The Spring Cloud Stream official link below says "the two properties are always required by certain binders (for example, the Kafka binder) in order to ensure that data are split correctly across multiple consumer instances"

But the Spring Cloud Stream official link below says "With Kafka, if autoRebalanceEnabled is true (default), Kafka takes care of distributing partitions across instances, and these properties are not required."

Question 2: if using RabbitMQ, how to set up these 2 properties for each instance?

Upvotes: 0

Views: 23

Answers (0)

Related Questions