python kafka 代码示例

以下是一个简单的 Python Kafka 代码示例，用于向 Kafka 主题发送消息:

from kafka import KafkaProducer

# 设置 Kafka 服务器地址和主题名称
bootstrap_servers = ['localhost:9092']
topicName = 'test_topic'

# 创建 Kafka 生产者
producer = KafkaProducer(bootstrap_servers = bootstrap_servers)

# 发送消息到 Kafka 主题
producer.send(topicName, b'Hello, World!')

# 关闭 Kafka 生产者连接
producer.close()

请注意，这只是一个简单的示例，您需要根据您的实际场景修改代码以满足您的需求。