1.acks
kafka消息的可靠性选项
- acks=0
生产者写入消息后不需要broker回应。如果broker没有收到消息,生产者也不知道。
可靠性最差,吞吐量最高 - acks=1
只要集群的首领节点收到消息,生产者就会收到一个来自服务器的成功响应。 - acks=all
只有当所有参与复制的节点全部收到消息时,生产者才会收到一个来自服务器的成功响应。
可靠性最强,吞吐量最低
2. compression.type
默认情况下,消息发送时不会被压缩。该参数可以设置为snappy,gzip或lz4。
使用压缩可以降低网络传输开销和存储开销,但会加重cpu负担。
网友评论