将kafka控制台输出提取为变量答案

【问题标题】：Extracting kafka console output as a variable将kafka控制台输出提取为变量
【发布时间】：2021-01-16 05:32:39
【问题描述】：

我已经编写了一个消费者程序来将主题中的消息打印到控制台。但我需要它作为变量来获取和使用它。

我的程序如下：

from kafka import KafkaConsumer

consumer = KafkaConsumer('track_id',bootstrap_servers='localhost:9099')

for msg in consumer:
    x = msg.value.decode()
    print(x)

如何将输出打印到控制台并将其用作程序中的变量？

【问题讨论】：

你已经有了变量，它是x，除非我不明白这个问题
如果我尝试在 for 循环之外打印变量，则没有任何反应

标签： python python-3.x apache-kafka

【解决方案1】：

我用这个解决方法解决了它：

for msg in consumer:
    x = msg.value.decode()
    f = open('track.txt','w')
    print(x, file=f)
    exit()

【讨论】：