producer比较重要的配置

1.acks

kafka消息的可靠性选项

  • acks=0
    生产者写入消息后不需要broker回应。如果broker没有收到消息,生产者也不知道。
    可靠性最差,吞吐量最高
  • acks=1
    只要集群的首领节点收到消息,生产者就会收到一个来自服务器的成功响应。
  • acks=all
    只有当所有参与复制的节点全部收到消息时,生产者才会收到一个来自服务器的成功响应。
    可靠性最强,吞吐量最低
2. compression.type

默认情况下,消息发送时不会被压缩。该参数可以设置为snappy,gzip或lz4。
使用压缩可以降低网络传输开销和存储开销,但会加重cpu负担。

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容