python接kafka

你可以使用 Kafka-Python 库来在 Python 中接收和发送 Kafka 消息。首先，确保已经安装了该库，可以使用以下命令安装：

pip install kafka-python

接下来，你可以使用以下代码示例来创建一个 Kafka 消费者并订阅一个主题：

from kafka import KafkaConsumer

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

# 循环消费消息
for message in consumer:
    print(message.value.decode('utf-8'))

在上面的代码中，你需要将 `'your_topic_name'` 替换为你要订阅的 Kafka 主题的名称，并将 `'your_bootstrap_servers'` 替换为你的 Kafka 服务器地址。

如果你想发送消息到 Kafka，可以使用以下代码示例：

from kafka import KafkaProducer

# 创建生产者对象
producer = KafkaProducer(bootstrap_servers='your_bootstrap_servers')

# 发送消息
producer.send('your_topic_name', b'your_message')

在上面的代码中，你需要将 `'your_topic_name'` 替换为你要发送消息的 Kafka 主题的名称，并将 `'your_bootstrap_servers'` 替换为你的 Kafka 服务器地址。而 `'your_message'` 则是要发送的消息内容。

这只是一个简单的示例，你可以根据自己的需求进行更多的定制和扩展。希望能对你有所帮助！