Python Kafka 数据推送：入门指南及代码示例

要使用 Python 向 Kafka 推送数据，需要安装 Kafka Python 包。可以使用 pip 命令安装：

pip install kafka-python

然后，可以使用以下代码示例将消息推送到 Kafka 主题中：

from kafka import KafkaProducer

producer = KafkaProducer(bootstrap_servers=['localhost:9092'])
topic = 'test-topic'

# 将消息推送到主题
producer.send(topic, b'Hello, Kafka!')

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

在此示例中，我们创建了一个生产者对象，并使用bootstrap_servers参数指定了 Kafka 集群的地址。然后，我们将消息推送到名为test-topic的主题中，并关闭了生产者连接。

您可以根据需要更改主题名称和消息内容。