2017-06-21 107 views
0

我正在使用春季云流kafka。我已将kafka的属性设置如下:无法在春季云流kafka中设置kafka属性

spring.cloud.stream.bindings.output.contentType=application/x-java-object;type=com.example.demo.KafkaApplication.Message 
eureka.client.service-url.default-zone=http://172.16.165.26:8761/eureka/ 
spring.cloud.stream.kafka.binder.zkNodes=10.6.22.20 
#spring,cloud.stream.kafka.binder.brokers=10.6.22.20 
spring.kafka.bootstrap-servers=10.6.22.20:9092 
#spring.kafka.consumer.group-id=example-consumer-1 
spring.cloud.stream.instanceCount=1 
spring.cloud.stream.instanceIndex=0 
spring.kafka.consumer.auto-offset-reset=earliest 
spring.cloud.stream.kafka.bindings.output.group=example-consumer-1 
spring.cloud.stream.kafka.bindings.output.consumer.instanceCount=1 
spring.cloud.stream.kafka.bindings.output.consumer.instanceIndex=0 
spring.cloud.stream.kafka.bindings.output.consumer.resetOffsets=true 
spring.cloud.stream.kafka.bindings.output.consumer.startOffset=earliest 

属性无效。卡夫卡正在采取一个匿名组,而不是给定的财产。所以与开始偏移

回答