kafka consumer zookeeper 交互邏輯

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