python连接kafka的方法是什么

47次阅读
没有评论

共计 663 个字符,预计需要花费 2 分钟才能阅读完成。

要连接 Kafka,可以使用 Kafka-Python 库。以下是一个简单的示例代码,演示如何连接 Kafka 并发送消息:

from kafka import KafkaProducer, KafkaConsumer
# 连接 Kafka 生产者
producer = KafkaProducer(bootstrap_servers='localhost:9092')
# 发送消息
producer.send('my_topic', b'Hello, Kafka!')
# 关闭生产者连接
producer.close()
# 连接 Kafka 消费者
consumer = KafkaConsumer('my_topic', bootstrap_servers='localhost:9092')
# 消费消息
for message in consumer:
print(message.value.decode('utf-8'))
# 关闭消费者连接
consumer.close()

在上面的示例中,我们首先使用 KafkaProducer 类连接到 Kafka,并使用 send() 方法发送消息到名为 my_topic 的主题。
然后,我们使用 KafkaConsumer 类连接到 Kafka,并使用 consumer() 方法订阅 my_topic 主题。然后,使用 for 循环遍历消费者对象以接收消息,并使用 value 属性获取消息的值。
最后,我们关闭生产者和消费者的连接。
请注意,上述示例假设 Kafka服务器 在本地运行,且端口号为 9092。您需要根据您的 Kafka 服务器配置进行适当的更改。

丸趣 TV 网 – 提供最优质的资源集合!

正文完
 
丸趣
版权声明:本站原创文章,由 丸趣 2023-12-22发表,共计663字。
转载说明:除特殊说明外本站除技术相关以外文章皆由网络搜集发布,转载请注明出处。
评论(没有评论)