正在提取kafka控制台输出作为变量

Question

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

我的程序如下：

from kafka import KafkaConsumer
consumer = KafkaConsumer('track_id',bootstrap_servers='localhost:9099')
for msg in consumer:
x = msg.value.decode()
print(x)

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

Answer 1

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

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