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')

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