kafka consumer zookeeper 交互逻辑

consumer操作 1. kafka各组件通信采用TCP协议。broker端口号:9092,zookeeper端口号:2181。 2. consumer启动时(绿色虚线),与brokers建立一个TCP长连接,生成SimpleConsumer实例,并返回broker配置文件中的域名。 3. consumer根据域名访问brokers获取topic、partition、offset(蓝色虚线)。
相关文章
相关标签/搜索