小编zhe*_*gui的帖子

如何在ConsumerRecord中获取字段

我写了一个python脚本:

#!/usr/bin/env python
from kafka import KafkaConsumer
consumer = KafkaConsumer('dimon_tcpdump',group_id='zhg_group',bootstrap_servers='192.168.100.9:9092')
for msg in consumer:
    print msg
    # process mes here
Run Code Online (Sandbox Code Playgroud)

msg的输出就像:

ConsumerRecord(topic=u'ditopic', partition=0, offset=6280, timestamp=None, timestamp_type=None, key=None, value='myvalue')
Run Code Online (Sandbox Code Playgroud)

我知道输出是namedtuple形式。

我的问题是:如何获得特定领域的ConsumerRecord?例如,我想将值字符串分配给变量。

python namedtuple apache-kafka

5
推荐指数
1
解决办法
3943
查看次数

标签 统计

apache-kafka ×1

namedtuple ×1

python ×1