kafka收发消息延时很高

服务器目前使用的是kafka+zookeeper standalone模式,想实现类似linux消息队列的功能,即将topic的partition和replication均设置为1,brokers也只有一台服务器。
现在我用pykafka每半分钟向队列中发送一个JSON格式的字符串,另一个线程用iter接受队列消息,收到消息就立即print出来。但是发送和接受之间平均延时超过了两秒,请问是partition等参数设置为1的原因吗?







发表于: 2月前   最后更新时间: 2月前   游览量:272
上一条: 到头了!
下一条: 已经是最后了!

评论…


  • 补充一下,producer和consumer都只有一个,想对最简单的消息队列进行一个测试
    • 我的代码是在发送成功后计时,然后再接收成功后计时(两个线程)这个时延很高,和您说的批量发送是似乎是没有关系?
        • 噢噢我尝试过啦,时延降到了0.2S左右,十分感谢您的帮助!
          另外producer批处理的等待过程,kafka并没有让这批消息进队列是吗?
          • 评论…
            • in this conversation