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.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