python将数据写入topic

在Python中，要将数据写入Kafka主题（Topic），你需要使用`kafka-python`库，这是一个用于与Apache Kafka交互的客户端库。首先，需要安装这个库，可以使用pip命令：

pip install kafka-python

下面是一个简单的例子，展示如何创建一个Producer（生产者），连接到Kafka集群，并将数据写入指定的主题：

from kafka import KafkaProducer

# 设置Kafka服务器地址和端口
bootstrap_servers = 'localhost:9092'

# 创建Producer实例
producer = KafkaProducer(bootstrap_servers=bootstrap_servers,
                         value_serializer=lambda v: json.dumps(v).encode('utf-8'))

# 要发送的数据（这里假设是一个字典）
data = {
    "key": "example",
    "value": "Hello, Kafka!"
}

# 发送消息到主题
future = producer.send(topic='your_topic_name', value=data)

# 等待消息被成功发送，或超时处理
try:
    record_metadata = future.get(timeout=5)
except Exception as e:
    print(f"Error sending message: {e}")
else:
    print(f"Message sent to topic {record_metadata.topic} at offset {record_metadata.offset}")

# 关闭Producer
producer.close()

在这个示例中，你需要替换`localhost:9092`为你的实际Kafka服务器地址，`your_topic_name`为你想要写入的主题名。