java - 当我在我的 Kafka 生产者中为 all 设置 acks 时,得到 acks = -1
问题描述
我在我的 Kafka 生产者上设置了以下属性:
properties.setProperty(ProducerConfig.ACKS_CONFIG, "all");
当我启动我的应用程序时,我acks = -1
在ProducerConfig values
. 为什么是这样?
解决方案
对于生产者配置,acks
属性-1
等于all
.
来自 Kafka 文档的生产者配置:
acks=all 这意味着领导者将等待完整的同步副本集来确认记录。这保证了只要至少一个同步副本保持活动状态,记录就不会丢失。这是最有力的保证。这相当于 acks=-1 设置。
推荐阅读
- java - 从 Github 下载 JAVA 代码后,类文件总是被锁定,我永远无法编译或运行我的代码
- php - 用户登录PHP后重定向到同一页面
- rust - 让算法在 Rust 中同时使用 f32 和 f64 所需的 Rust 特征
- wpf - WPF Metro 按钮中的多种样式资源
- c++ - 如何将到达图形视图右侧(末端)的 QGraphicsPixmapItem 移动到左侧(开始)侧(就像蛇游戏中发生的事情)
- java - 如何使 Selenium webdriver 等待元素将其属性更改为 Java 中的其他内容
- arrays - 将参数和数组的组合从 linux shell 脚本传递到另一个 shell 脚本
- ios - 当我尝试将 GooglePlacesPicker 添加到 Swift 项目时出现编译错误
- python - 如何在不使用 python 保留目录的情况下提取文件夹中的所有 .zip 扩展名?
- arrays - 如何在 Swift 中将字符串/数组中的所有其他字母大写?