0

我有一个属于客户端的 kafka 生产者,其客户端 ID -“p1”,配额为 50 MBps。

现在我使用“bin/kafka-producer-perf-test.sh”测试了我的生产者的性能,当写入没有副本的分区时,我能够获得接近 50 MBps 的吞吐量。

我在具有三个副本的分区上尝试了相同的实验。但这次吞吐量降低到 30 MBps。

我的问题是,即使存在副本,kafka 是否不应该允许生产者仍然获得 50 MBps 的吞吐量?系统中没有其他任何东西在运行,所以我不确定为什么会这样?

4

1 回答 1

0

你改变了acks生产者的配置吗?根据您的描述,它似乎acks设置为all,因此生产者等待发送的数据将在三个影响吞吐量的代理之间复制。如果您没有更改ackstry 将其设置为0,则生产者根本不会等待服务器的任何确认,只是看看它是否会影响吞吐量。

于 2017-05-02T14:33:16.763 回答