在上面的例子中,因为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 |