课程
/后端开发
/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 回答老师怎么校验用户名和密码啊
2 回答zookeeper的端口号2181和broker的端口号9092为什么不同呢？
2 回答老师好,想问下KafKa已经具有流处理能力,为什么很多项目还都是组合Kafka和Flink, 仅应用KafKa的消息队列特性呢,搞的工序多了一道?
