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消息以字节的形式传输，因此我们需要将其解码为可读的字符串。