阅读背景:

关于springcloud kafka binder的一个关于consumer group设置的一个bug

来源:互联网 

我们可以通过spring.cloud.stream.kafka.bindings.springCloudBusInput.consumer.group来指定默认总线topic:spingCloudBus的consumer group,比如设置成${spring.application.name}:${spring.application.index},这样我们在kafka manager界面上可以方便的识别出某个服务的offset消费情况。我们可以通过spring.cloud.stream.kafka.bindings.spring




你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: