Python Kafka消费监控脚本(Python 2/3)

Python Kafka消费监控脚本(Python 2/3)

以下是一个使用Python脚本监控Kafka消费情况的示例，适用于Python 2和Python 3:

Python 2:

from kafka import KafkaConsumer

# 创建Kafka消费者
consumer = KafkaConsumer('your_topic_name', bootstrap_servers='your_bootstrap_servers')

# 从Kafka主题中消费消息
for message in consumer:
    # 处理消息的逻辑
    print 'Received message: {}'.format(message.value)

# 关闭消费者连接
consumer.close()

Python 3:

from kafka import KafkaConsumer

# 创建Kafka消费者
consumer = KafkaConsumer('your_topic_name', bootstrap_servers='your_bootstrap_servers')

# 从Kafka主题中消费消息
for message in consumer:
    # 处理消息的逻辑
    print('Received message: {}'.format(message.value))

# 关闭消费者连接
consumer.close()

说明:

• 确保你已经安装了kafka-python库 (可以使用pip install kafka-python安装).
• 将your_topic_name和your_bootstrap_servers替换为你自己的Kafka主题和引导服务器的地址.
• 此脚本将不断消费Kafka主题中的消息，并将消息内容打印到控制台.
• Python 2已于2020年1月1日停止维护，建议你尽快迁移到Python 3以获得更好的支持和性能.