kafka consumer zookeeper 交互邏輯

consumer操作 1. kafka各組件通信採用TCP協議。broker端口號:9092,zookeeper端口號:2181。 2. consumer啓動時(綠色虛線),與brokers建立一個TCP長連接,生成SimpleConsumer實例,並返回broker配置文件中的域名。 3. consumer根據域名訪問brokers獲取topic、partition、offset(藍色虛線)。
相關文章
相關標籤/搜索