使用appation.yml在春靴中设置Kafka中的分区数

a64a0gku  于 2022-10-07  发布在  Kafka
关注(0)|答案(1)|浏览(211)

如何使用application.yml在Spring Boot中设置Kafka中的分区数。

kafka:
  zookeeper:
    host: localhost:2181
    groupId: group1
  topic: test_kafkaw
  bootstrap:
    servers: localhost:9092
n3h0vuf2

n3h0vuf21#

如果您使用的是Spring Cloud Stream,您可以在APPLICATION.YML/APPLICATION.PROPERTIES中按Kafka主题指定分区数:

spring.cloud.stream.bindings.<binding-name>.producer.partition-count

Kafka绑定器使用生产者的‘artitionCount’设置来创建具有给定分区计数的主题。

如果您使用的是用于ApacheKafka的Spring,则可以使用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

相关问题