课程
/后端开发
/Java
/Kafka流处理平台
spring.kafka.consumer.group-id怎么填呢,在搭建kafka服务的时候没看到有指定这个啊?
2021-01-31
源自:Kafka流处理平台 4-3
正在回答
@KafkaListener(topics = {"${kafka.test.topic}"},groupId = "xiaofeng1")
public void consumer(String message) {
logger.info("groupId = xiaofeng1, message = " + message);
}
举报
作为模块解耦和大数据处理黏合剂的不二之选Kafka,你值得拥有!
1 回答INVALID_TOPIC_EXCEPTION 这个问题怎么处理?
4 回答请问提示broker不可用怎么处理
1 回答老师怎么校验用户名和密码啊
1 回答ppt在哪里下载呢
2 回答zookeeper的端口号2181和broker的端口号9092为什么不同呢?
购课补贴联系客服咨询优惠详情
慕课网APP您的移动学习伙伴
扫描二维码关注慕课网微信公众号