了解Kafka写入速度
Understand Kafka write speed
鉴于
1. 五机Kafka集群
2. 1 个主题,1 个分区
3. 消息的持久存储
4. 每条消息1 KB
5. 10 个生产者
现在,这个集群的最大写入能力是否等于一个 java 线程写入磁盘的最大写入能力?
如果不是,会是什么?
如果您只有一个分区,那么 kafka 无法扩展您的主题并且只能使用 5 个实例集群中的一台机器。
无法判断您的 java 代码编写得如何,但结果将与我假设的 kafka 类似,只有细微差别,因为 kafka 针对磁盘写入进行了优化。
你不能真的说它会是 "EQUAL TO" 因为它不准确,但是是的,假设磁盘 I/O 是你的瓶子,写入容量将几乎相同 -脖子。考虑到 Kafka 针对此任务进行了优化,并且可能比标准 Java 应用程序的原始磁盘写入性能更好。
鉴于
1. 五机Kafka集群
2. 1 个主题,1 个分区
3. 消息的持久存储
4. 每条消息1 KB
5. 10 个生产者
现在,这个集群的最大写入能力是否等于一个 java 线程写入磁盘的最大写入能力? 如果不是,会是什么?
如果您只有一个分区,那么 kafka 无法扩展您的主题并且只能使用 5 个实例集群中的一台机器。
无法判断您的 java 代码编写得如何,但结果将与我假设的 kafka 类似,只有细微差别,因为 kafka 针对磁盘写入进行了优化。
你不能真的说它会是 "EQUAL TO" 因为它不准确,但是是的,假设磁盘 I/O 是你的瓶子,写入容量将几乎相同 -脖子。考虑到 Kafka 针对此任务进行了优化,并且可能比标准 Java 应用程序的原始磁盘写入性能更好。