小编Ash*_*sle的帖子

Kafka 中消息的大小开销是多少?

假设原始消息大小为 500 字节(在发送到 Kafka 之前)。那么消息发送到Kafka后的大小是多少呢?如果我们使用任何压缩会怎样?

附加信息:我将一个大小为 2048 字节的 ByteBuffer 放入一个主题(具有单个分区),没有任何键。

Topic name: ub3
Path: /data/kafka-logs/ub3-0

[hdpusr@hdpdev2 ub3-0]$ $KAFKA_HOME/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list hdpdev2:8092 --topic ub3 --time -1 --offsets 1 | awk -F ":" '{sum += $3} END {print sum}'
184
[hdpusr@hdpdev2 ub3-0]$ du -sh *
10M     00000000000000000000.index
448K    00000000000000000000.log
10M     00000000000000000000.timeindex
4.0K    leader-epoch-checkpoint
[hdpusr@hdpdev2 ub3-0]$
[hdpusr@hdpdev2 ub3-0]$
[hdpusr@hdpdev2 ub3-0]$ $KAFKA_HOME/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list hdpdev2:8092 --topic ub3 --time -1 --offsets 1 | awk -F ":" '{sum += $3} END {print sum}'
86284
[hdpusr@hdpdev2 ub3-0]$ …
Run Code Online (Sandbox Code Playgroud)

java apache-kafka

2
推荐指数
1
解决办法
1777
查看次数

标签 统计

apache-kafka ×1

java ×1