最新回答 / 蛋蛋淡淡定
@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
最新回答 / 慕粉4095877
同一时点，主（leader） partition 只会存在于一个 broker 上，如果改broker 挂掉了，存在于其他 broker 上的从（follwer） partition会通过zookeeper服务提供的竞选机制升级为主（leader）partition。 通常一个 broker 里会存储多个不同 topic 的 partition
2019-10-04
最新回答 / 慕粉3535685
不相同。一个topic包含多个partition，topic携带的produer的消息经过一定的算法，分配到多个partition上的message上面，它们组合在一起构成一条完整的消息
2019-08-30