2017-06-21 95 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 

屬性無效。卡夫卡正在採取一個匿名組,而不是給定的財產。所以與開始偏移

回答

相關問題