如何使用application.yml在Spring Boot中设置Kafka中的分区数。
application.yml
kafka: zookeeper: host: localhost:2181 groupId: group1 topic: test_kafkaw bootstrap: servers: localhost:9092
n3h0vuf21#
如果您使用的是Spring Cloud Stream,您可以在APPLICATION.YML/APPLICATION.PROPERTIES中按Kafka主题指定分区数:
spring.cloud.stream.bindings.<binding-name>.producer.partition-count
Kafka绑定器使用生产者的‘artitionCount’设置来创建具有给定分区计数的主题。
如果您使用的是用于ApacheKafka的Spring,则可以使用TopicBuilder进行配置-类似于:
TopicBuilder
@Bean public NewTopic topic() { return TopicBuilder.name("topic1") .partitions(10) .replicas(1) .build(); }
TopicBuilder参考:https://docs.spring.io/spring-kafka/docs/current/api/org/springframework/kafka/config/TopicBuilder.html
1条答案
按热度按时间n3h0vuf21#
如果您使用的是Spring Cloud Stream,您可以在APPLICATION.YML/APPLICATION.PROPERTIES中按Kafka主题指定分区数:
Kafka绑定器使用生产者的‘artitionCount’设置来创建具有给定分区计数的主题。
如果您使用的是用于ApacheKafka的Spring,则可以使用
TopicBuilder
进行配置-类似于:TopicBuilder参考:https://docs.spring.io/spring-kafka/docs/current/api/org/springframework/kafka/config/TopicBuilder.html