Python KafkaConsumer 重定向 json 输出（回复）到文件

Question

我在 Python 中使用 Kafkaconsumer 消费 Kafka 消息。

我从 Kafka 得到的回复是 json 格式。我想知道如何使用我从 Kafka 收到的回复创建一个 json 文件。

这是我的循环遍历消息的 for 循环

Consumer = KafkaConsumer(topic, groupid, Bootstrap server....)

For message in Consumer
   message =message.value
    # Here I want to create a new file

我想要名为 Reply.json 的文件并在文件中写入消息。

Answer 1

Kafka 只是一个实现细节。打开文件并写入

with open('Reply.json', 'a'):
    for r in consumer:
        f.write(str(r.value))
        f.write('\n')

请注意，这是一个无限循环，因此您的文件可能会变得非常大（如果磁盘用完，您的计算机可能会崩溃 space）

Python KafkaConsumer 重定向 json 输出（回复）到文件

Python KafkaConsumer redirect json output (reply) to file

python

json

apache-kafka