返回到文章

采纳

编辑于

kafka收发消息延时很高

kafka

服务器目前使用的是kafka+zookeeper standalone模式,想实现类似linux消息队列的功能,即将topic的partition和replication均设置为1,brokers也只有一台服务器。

现在我用pykafka每半分钟向队列中发送一个JSON格式的字符串,另一个线程用iter接受队列消息,收到消息就立即print出来。但是发送和接受之间平均延时超过了两秒,请问是partition等参数设置为1的原因吗?