python操作kafka

在Python中操作Kafka可以使用kafka-python库。以下是一个简单的示例代码，演示如何发送和接收消息到Kafka主题：

首先，使用pip安装kafka-python库：

pip install kafka-python

然后，可以按照以下方式发送消息到Kafka主题：

from kafka import KafkaProducer

# 创建生产者
producer = KafkaProducer(bootstrap_servers='localhost:9092')

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

# 刷新并关闭生产者
producer.flush()
producer.close()

接下来，可以使用以下代码从Kafka主题接收消息：

from kafka import KafkaConsumer

# 创建消费者
consumer = KafkaConsumer('my_topic', bootstrap_servers='localhost:9092')

# 从主题中获取并打印消息
for message in consumer:
    print(message.value.decode('utf-8'))

# 关闭消费者
consumer.close()

在以上示例中，我们使用`KafkaProducer`类创建了一个生产者对象，并使用`send`方法发送了一条消息到名为`my_topic`的Kafka主题。在消费者部分，我们使用`KafkaConsumer`类创建了一个消费者对象，并通过迭代遍历获取并打印从主题中接收到的消息。

请确保将`bootstrap_servers`参数设置为正确的Kafka服务器地址和端口。