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 (将#修改为@）