如何解决Python 3 Confluent Kafka在单个函数中运行生产者和使用者
我正在尝试在单个函数中运行Producer和Consumer。
流程如下:
消息到达->从主题1消费->转换->产生到主题2
如果我以这种模式实例化生产者和消费者(首先是生产者,然后是消费者),那么它将正常工作。
def __init__(self,producer_config,consumer_config)
self.producer = Producer(**producer_config)
self.consumer_config = consumer_config
self.consumer = Consumer(**consumer_config)
self.consumer.subscribe([topic1])
但是,如果我先颠倒顺序并先实例化“消费者”,然后再实例化“生产者”,
def __init__(self,consumer_config)
self.consumer_config = consumer_config
self.consumer = Consumer(**consumer_config)
self.consumer.subscribe([topic1])
self.producer = Producer(**producer_config)
我收到错误消息:
{“级别”:“错误”,“消息”:“ Kafka使用者错误:KafkaError {code = GROUP_AUTHORIZATION_FAILED,val = 30,str =“ JoinGroup失败:代理:组授权失败”}“}
我只是想知道这是否按照预期的方式以及可能的原因进行操作。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。