Red Hat Summit 红帽全球峰会支持控制台（Console）开发人员开始试用联系人

191.8. 在 Kafka 使用者中使用手动提交

从 Camel 2.21 开始提供

默认情况下，Kafka 使用者将使用自动提交，其中偏移将使用给定间隔在后台自动提交。

如果要强制手动提交，您可以使用 Camel Exchange 中的 KafkaManualCommit API，存储在消息标头中。这要求通过将 KafkaComponent 或端点上的 allowManualCommit 设置为 true 来打开手动提交，例如： 

KafkaComponent kafka = new KafkaComponent();
kafka.setAllowManualCommit(true);
...
camelContext.addComponent("kafka", kafka);
Copy to Clipboard Toggle word wrap

然后，您可以使用 Java 代码（如 Camel 处理器）的 KafkaManualCommit ： 

public void process(Exchange exchange) {
    KafkaManualCommit manual =
        exchange.getIn().getHeader(KafkaConstants.MANUAL_COMMIT, KafkaManualCommit.class);
    manual.commitSync();
}
Copy to Clipboard Toggle word wrap

这将强制进行同步提交，它将阻止到提交在 Kafka 上确认，或者抛出异常。

如果要使用 KafkaManualCommit 的自定义实现，您可以在 KafkaComponent 中配置自定义 KafkaManualCommitFactory，用于创建自定义实现实例。

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务，以及可以信赖的内容，帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情，请参阅红帽博客.

關於紅帽

我们提供强化的解决方案，使企业能够更轻松地跨平台和环境（从核心数据中心到网络边缘）工作。

Theme

© 2025 Red Hat