用python写一段Kafka连接flume的代码

以下是一个简单的Python代码示例，演示如何使用kafka-python库连接Kafka和Flume：

from kafka import KafkaProducer
import json

# Connect to Kafka
producer = KafkaProducer(bootstrap_servers=['localhost:9092'])

# Send messages to Kafka
for i in range(10):
    data = {'message': 'Hello, Kafka!', 'id': i}
    producer.send('flume_topic', json.dumps(data).encode('utf-8'))

# Close the Kafka connection
producer.close()

这段代码使用kafka-python库连接到Kafka，并向名为“flume_topic”的主题发送10条消息。要将消息发送到Flume，请确保在Flume配置文件中正确配置了Kafka Source和Sink。