AWS MSK 使用 shell 命令但不使用 python

问题描述

我使用两个代理创建了一个 AWS MSK 实例。我可以使用 kafka#s shell 命令（kafka-console-producer.sh 和 kafka-console-consumer.sh）使用它来生成和使用消息，但问题是，它不适用于 kafka python 库。

consumer = KafkaConsumer(
      bootstrap_servers=["address_of_broker_1:9092","address_of_broker_1:9092"],auto_offset_reset='latest',enable_auto_commit=True,api_version=(2,2),group_id='group8',fetch_max_wait_ms=5)
consumer.subscribe(['test1'])

for msg in consumer:
    print(msg)

这不起作用，因为

sudo sh kafka-consumer-groups.sh --bootstrap-server address_of_broker1:9092,address_of_broker2:9092 --list --all-groups

这仅显示 2 个默认消费者

amazon.msk.canary.group.broker-1
amazon.msk.canary.group.broker-2 

然而，当我使用 kafka-console-consumer.sh 时，会在列表中显示一个新添加的消费者。

问题是，python 代码没有显示任何错误信息。这就是为什么我完全一无所知。

谁能告诉我可能发生的事情或者我在哪里可以看到 AWS MSK 中的错误日志

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）