Kafka-Python 消费者示例代码 - 从主题读取消息

以下是 kafka-python 消费者的基本示例代码：

from kafka import KafkaConsumer

# 创建消费者实例
consumer = KafkaConsumer('my_topic', bootstrap_servers=['localhost:9092'])

# 从主题中获取消息
for message in consumer:
    print(message.value.decode('utf-8'))

在上面的示例代码中，我们创建了一个名为 'my_topic' 的消费者实例，然后使用 for 循环从主题中获取消息并打印出来。

请注意，我们在打印消息之前使用 decode('utf-8') 方法来将消息从字节转换为字符串。这是因为 Kafka 消息以字节的形式传输，因此我们需要将其解码为可读的字符串。