rpmdeb 2019-09-05 15:56 采纳率: 0%
浏览 1820

python消费kafka数据,为什么前面取几次都取不到?

python 消费kafka数据时,刚开始连接时为什么取不到数据?

代码如下:


# -*- coding:utf8 -*-
from kafka import KafkaConsumer
from kafka import TopicPartition
import kafka
import time

# 测试kafka  poll方法能拉取多少的记录

consumer = KafkaConsumer(
    bootstrap_servers=['192.168.13.202:9092'],
    group_id='group-1',
    auto_offset_reset='earliest',
    enable_auto_commit=False)

consumer.subscribe('test')

print ("t1",time.time())
while True:
    print("t2", time.time())
    msg = consumer.poll(timeout_ms=100, max_records=5)  # 从kafka获取消息
    # print (len(msg))

    for i in msg.values():
        for k in i:
            print(k.offset, k.value)
    time.sleep(1)

打印的结果却是

t1 1567669170.438951
t2 1567669170.438951
t2 1567669171.8450315
t2 1567669172.945094
t2 1567669174.0471573
t2 1567669175.1472201
0 b'{"ast":"\xe7\x82\xb"}'
1 b'{"ast":"","dm":2}'
2 b'{"ast":"12"}'
3 b'{"ast":"sd"}'
4 b'{"ast":"12ds"}'
t2 1567669176.1822793

为什么连接上kafka之后,会取5次才会取到数据?

  • 写回答

1条回答 默认 最新

  • dabocaiqq 2019-09-06 08:34
    关注
    评论

报告相同问题?

悬赏问题

  • ¥30 帮我写一段可以读取LD2450数据并计算距离的Arduino代码
  • ¥15 C#调用python代码(python带有库)
  • ¥15 矩阵加法的规则是两个矩阵中对应位置的数的绝对值进行加和
  • ¥15 活动选择题。最多可以参加几个项目?
  • ¥15 飞机曲面部件如机翼,壁板等具体的孔位模型
  • ¥15 vs2019中数据导出问题
  • ¥20 云服务Linux系统TCP-MSS值修改?
  • ¥20 关于#单片机#的问题:项目:使用模拟iic与ov2640通讯环境:F407问题:读取的ID号总是0xff,自己调了调发现在读从机数据时,SDA线上并未有信号变化(语言-c语言)
  • ¥20 怎么在stm32门禁成品上增加查询记录功能
  • ¥15 Source insight编写代码后使用CCS5.2版本import之后,代码跳到注释行里面