文章/答案/技术大牛

发布

社区首页 >问答首页 >交易型卡夫卡生产者-消费滞后加倍

问交易型卡夫卡生产者-消费滞后加倍
EN

Stack Overflow用户

提问于 2020-12-02 13:16:40

回答 1查看 285关注 0票数 1

我们有一个基于spring引导的交易型卡夫卡生产者！所使用的版本如下

spring-boot-starter-parent - 2.3.0.RELEASE
spring-kafka -2.5.0.

我们的kafka (集群)版本是2.1.x！

作为生产者，我们启用了幂等功能，定义了事务性id前缀，并在事务中执行了kafka模板调用。我们还有一个隔离级别设置为只读提交的使用者！

这是我们遇到的一种行为，我们不知道该如何推断，

10!)

Consumer
生产者发送n-事件(10)
(不运行)滞后显示为n-事件的两倍(20，而生产者只发送了n-events ( sent ))，只消耗n-事件(10)--与生成的

f 217完全相同。

想不出为什么会有什么原因，但又想查证专家的意见，试着从官方资料中找出，但到目前为止还不走运！希望这不是太笼统。说到滞后，这是意料之中的吗？延迟是生产者发送的原始条目数量的两倍(可能是因为生产者发送的每个事件有一个条目具有事务信息)？

apache-kafka

spring-kafka

回答 1

Stack Overflow用户

发布于 2020-12-17 03:59:03

如果您注意到所使用的消息的偏移量，它可能是备用的。0，2，4，6.这是因为在每个事务之后记录了一个“提交标记”消息。此消息使用主题的偏移量。所以1,3,5..。将被标记所消耗。

由于消费者滞后观察到偏移差，最后消耗的和当前的偏移之间的滞后是双倍的。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/65108841

复制

相似问题

问交易型卡夫卡生产者-消费滞后加倍
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问交易型卡夫卡生产者-消费滞后加倍EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问交易型卡夫卡生产者-消费滞后加倍
EN