我们计划使用3个Kafka经纪人和一个zookeeper节点。我们为每个主题保留了一个分区。但我们有一个严格的要求,延迟在5毫秒以下。我们正在使用ReactKafka客户端库https://github.com/akka/reactive-kafka.
e、 g.我们有一个生产商,每30毫秒生产128字节(约)数据,每50毫秒生产消费数据。
我们试过了
linger.ms=0
compression.type=none
acks=0
在制片方。
以50ms在用户端轮询
但一旦我们将生成频率增加到1秒,延迟就开始变得不可预测,从1毫秒到70毫秒。
那么,如果我们总是要求延迟在5ms以下,我们应该怎么做呢?在kafka代理、生产者和消费者级别需要做什么调优呢。
暂无答案!
目前还没有任何答案,快来回答吧!