InfraPub 为您找到相关结果 51

Kafka 3.0新特性全面曝光,真香!

就是点对点模式。如果每个消费者都是一个单独的Group,那么就是发布订阅模式。(二)说说Kafka通信过程原理吗?首先kafka broker启动的时候,会去向Zookeeper注册自己的ID(创建临时节点),这个ID可以配置也可以自动生成,同时会去订阅Zookeeper的brokers/ids路径,当有新的broker加入或者退时,可以得到当前所有broker信。生产者启动的时候会指定bootstrap.servers,通过指定的broker地址,Kafka就会和这些broker创建TCP连接(通常我们不用配置所有的broker服务器地址,否则kafka会和配置的所有broker都建立TCP连接)随便连接到任何一台broker之后,然后再发送请求获取元数据信息(包含有哪些主题、主题都有哪...阅读全文

博文 2022-04-28 16:02:11 mp.weixin.qq.com