Kafka消费者不从队列中读取消息。

可能的原因之一是消费者与生产者使用不同的 Topic 名称。需要确保消费者使用与生产者相同的 Topic 名称，在使用 KafkaConsumer API 时指定正确的 Topic 名称和 Group ID。

以下是一个示例，展示了如何使用 KafkaConsumer API 从 Topic 中读取消息：

from kafka import KafkaConsumer

consumer = KafkaConsumer('my-topic', group_id='my-group', bootstrap_servers=['localhost:9092'])

for message in consumer:
    print(message.value)

在此示例中，Kafka 消费者读取名为 my-topic 的 Topic 中的消息，并使用 my-group 作为 Group ID。请注意，bootstrap_servers 列表中的地址必须匹配您的 Kafka 集群的地址。