kafka consumer.subscribe用法代码

下面是一个简单的使用 Kafka Consumer 的 subscribe 方法消费消息的 Python 代码示例：

from kafka import KafkaConsumer

# 创建一个 KafkaConsumer 对象
consumer = KafkaConsumer(bootstrap_servers=['localhost:9092'], group_id='my-group')

# 订阅一个主题
consumer.subscribe(['my-topic'])

# 消费消息
for message in consumer:
    print(message)

在上面的代码中，我们使用了 `KafkaConsumer` 类创建了一个消费者对象，并通过 `subscribe` 方法订阅了一个主题。然后我们使用一个 for 循环遍历消费者对象，从而不断地消费消息。当有新的消息到达时，for 循环就会执行一次，并打印出消息内容。

需要注意的是，`subscribe` 方法接收的参数是一个主题列表，因此可以同时订阅多个主题。此外，`KafkaConsumer` 类的 `group_id` 参数指定了消费者所属的消费组，同一个消费组内的消费者会竞争消费同一主题的消息。