代码之家 › 专栏 › 技术社区 › Juh_

卡夫卡:如果承诺是在开始补偿之前发生的呢?

apache-kafka

Juh_ · 技术社区 · 6 年前

这不是我的代码,所以我正在发现(大部分)它。但是我在一些日志中发现( KafkaConsumer.committed KafkaConsumer.beginningOffset ). 例如,我有:

起始偏移=740000
内偏移=760000

KafkaConsumer.commitSync ,和 enable.auto.commit 错误)。但这不是问题所在。

基本上,这是应用程序陷入困境的潜在原因吗?

1 回复 | 直到 6 年前

Simon Clark 6 年前

根据 the docs ,如果有这样的无效偏移量, auto.offset.reset 将启动并使用您选择的设置(默认为 latest

文件中的措辞如下:

auto.offset.reset: What to do when there is no initial offset in Kafka or if the current offset does not exist any more on the server (e.g. because that data has been deleted)

推荐文章

yershalom · 同一消费群体中具有不同分区数量的不同卡夫卡主题

2 年前

Oskars Apinis · 将kafka从服务器迁移到docker容器

2 年前

Sravan Kumar · Apache kafka模式注册表问题

2 年前

Panadol Chong · 无法建立到节点1(localhost/127.0.0.1:9092)的连接。经纪人可能不在。甚至传入正确的端点[重复]

2 年前

MrSham · 如何确保旧版本0.10.0在卡夫卡中只处理一次

2 年前

TheTags · Kafka-PLC4X-Modbus/TCP-作业刮取期间异常

2 年前

Iheb Mar · 卡夫卡制作人/消费者粉碎每一秒的API调用

2 年前

hasherBaba · 在为Nifi编写流媒体服务时,如何解决Java的空指针异常?[闭门]

6 年前

phaigeim · 为storm consumer检查卡夫卡主题的偏移量

6 年前

Raman · Kafka流:POJO序列化/反序列化

6 年前