同时，Kafka为每个消费者分配一个Consumer ID，通常采用quotHostnameUUIDquot形式表示在Kafka中，规定了 每个消息分区 只能被同组的一个消费者进行消费 ，因此，需要在 Zookeeper 上记录 消息分区 与 Consumer 之间的关系，每个消费者一旦确定了对一个消息分区的消费权力，需要将其Consumer ID 写入到。
用confluentkafka替换kafkapython非常简单confluentkafka使用poll方法，它类似于上面提到的访问kafkapython的变通方案kafka_consumer = Consumer quot True，quot True，quotgroupidquot group_id，quotbootstrapserversquot ，quotsecurityprotocolquot quot。
其实kafka客户端访问kafka是分两步走kafka对这两个参数的说明结合我们的例子如何让外部其他主机也能访问方案已经很明确了，就是发布一个KAFKA_ADVERTISED_LISTENERS到所有人都认识的地址这样不管是谁都通过统一的lt宿主主机9092地址来访问kafka让容器网络上的主机访问一个kafka地址，让宿主机网。
标签： kafka客户端host
文章来源：
菲律宾亚星公司
版权声明：凡本站注明内容来源：“菲律宾亚星公司”的所有作品，版权均属于“菲律宾亚星国际登录”，转载请必须注明中“菲律宾亚星开户”。违反者本网将追究相关法律责任。
评论列表
明确了，就是发布一个KAFKA_ADVERTISED_LISTENERS到所有人都认识的地址这样不管是谁都通过统一的lt宿主主机9092地址来访问kafka让容器网络上的主机访问一个kafka地址，让宿主机网。
之间的关系，每个消费者一旦确定了对一个消息分区的消费权力，需要将其Consumer ID 写入到。用confluentkafka替换kafkapython非常简单confluentkafka使用poll方法，它类似于上面提到的访问kafkapython的变通方案
kafka_consumer = Consumer quot True，quot True，quotgroupidquot group_id，quotbootstrapserversquot ，quotsecurityprotocolquot quot。其实ka
fka让容器网络上的主机访问一个kafka地址，让宿主机网。