动态kafka消费代码

以下是一个简单的动态 Kafka 消费代码示例：

from kafka import KafkaConsumer

# 创建 Kafka 消费者对象
consumer = KafkaConsumer(
    'my_topic',  # 消费的主题
    bootstrap_servers=['localhost:9092'],  # Kafka 服务器地址
    auto_offset_reset='latest',  # 消费者从最新的消息开始消费
    enable_auto_commit=True,  # 自动提交消费位移
    group_id='my_group'  # 消费者组 ID
)

# 循环消费消息
for message in consumer:
    print(message.value.decode('utf-8'))

这段代码使用 Python 的 Kafka 库，创建了一个 Kafka 消费者对象，并循环消费指定主题的消息。在消费时，我们可以对消息进行解码，以便正确地处理消息内容。

注意，这只是一个简单的示例代码，实际应用中可能需要根据具体需求进行修改和优化。