spring的cloud之kafka配置

Kafka配置

在上面的例子中,因为Kafka、ZooKeeper均运行于本地,因此咱们没有在测试程序中经过配置信息来指定Kafka和ZooKeeper的配置信息,就完成了本地消息总线的试验。可是咱们实际应用中,Kafka和ZooKeeper通常都会独立部署,因此在应用中都须要来为Kafka和ZooKeeper配置一些链接信息等。Kafka的整合与RabbitMQ不一样,在Spring Boot 1.3.7中并无直接提供的Starter模块,而是采用了Spring Cloud Stream的Kafka模块,因此对于Kafka的配置均采用了spring.cloud.stream.kafka的前缀,好比:spring

属性名 说明 默认值
spring.cloud.stream.kafka.binder.brokers Kafka的服务端列表 localhost
spring.cloud.stream.kafka.binder.defaultBrokerPort Kafka服务端的默认端口,当brokers属性中没有配置端口信息时,就会使用这个默认端口 9092
spring.cloud.stream.kafka.binder.zkNodes Kafka服务端链接的ZooKeeper节点列表 localhost
spring.cloud.stream.kafka.binder.defaultZkPort ZooKeeper节点的默认端口,当zkNodes属性中没有配置端口信息时,就会使用这个默认端口 2181