java - 了解Kafka写入速度

标签 java performance apache-kafka kafka-cluster

鉴于此
1. 五机Kafka集群
2. 1个主题,1个分区
3. 消息持久化存储
4.每条消息1KB
5. 10 个生产者

现在,这个集群的最大写入能力是否等于一个 Java 线程写入磁盘的最大写入能力? 如果不是,那会是什么?

最佳答案

如果您只有一个分区,那么 kafka 无法扩展您的主题并且只能使用 5 个实例集群中的一台机器。

无法判断您的 java 代码编写得如何,但结果将与我假设的 kafka 类似,但存在细微差异,因为 kafka 针对磁盘写入进行了优化。

关于java - 了解Kafka写入速度,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50713040/

相关文章:

java - 文件上传包不存在

sql-server - 基于SQL的加密性能

asp.net - 按值查找 TreeView 节点

java - 如何在未捕获的异常处理程序中重新启动kafka Stream应用程序?

java - 是否可以将分区添加到 Kafka 0.8.2 中的现有主题

apache-kafka - Apache Kafka 分区保证中的消息顺序

java - 如何绕程序中心旋转椭圆?

java - 当这些标记超过 10000 个时,如何对它们进行分组?

java - 安卓 HTTP : Make more than 1 asynctask request

angularjs - 如何在相同条件下为 ng-show 减少 AngularJS 中的观察者