2

We have created kafka topics with default replication-factor as 1, to update this we have added property spring.cloud.stream.kafka.binder.replication-factor: 3 in application.yaml which has no reflect on created topics in kafka.

spring cloud stream version used is Germantown.SR1

jlewkovich
  • 2,725
  • 2
  • 35
  • 49
Goushikaa Moorthi
  • 73
  • 1
  • 6

1 Answers1

2

The underlying AdminClient used by the binder and Spring for Apache Kafka to create/modify topics does not support changing the replication factor.

See this answer to see how to do it with command-line tools (kafka-reassign-partitions).

Gary Russell
  • 166,535
  • 14
  • 146
  • 179