最新回答 / 蛋蛋淡淡定
@KafkaListener(topics = {"${kafka.test.topic}"},groupId = "xiaofeng1")public void consumer(String message) {logger.info("groupId = xiaofeng1, message = " + message);}
2021-01-31
最赞回答 / 神秘陌生人
你可以这样理解，zookeeper和kafka是两个程序。这两个程序启动都有自己的默认端口，zookeeper的默认端口是2181，kafka的默认端口是9092。一台计算机上两个程序的所占用的端口是不能一样的，所以不能重复。9092是kafka的默认端口，写在kafka的配置文件里面的，你看视频里面老师启动kafka的时候指定了配置文件server.properties。
2020-05-17
大家可以参考https://github.com/doocs/advanced-java/blob/master/docs/high-concurrency/how-to-ensure-high-availability-of-message-queues.md 如果看不见图请多刷新几次
2020-04-23
