kafka事务消费offset不更新

使用kafka事务消费-转换-生产的模型。集群A使用这个模型向集群B发送消息后，offset不更新。集群A向集群A中的另一个topic发送消息后，offset会更新。请问下这是什么情况，是还需要更改什么配置码？

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除结题
收藏举报

2条回答默认最新

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
baskbull 2021-05-23 17:10
关注
你看一下offset自动提交的配置是打开还是关闭的，ENABLE_AUTO_COMMIT_CONFIGS

解决无用
评论打赏
分享
举报

评论

按下Enter换行，Ctrl+Enter发表内容

报告相同问题？

关注问题

kafka消费者创建不了 java kafka linux
2022-08-23 10:01

回答 1 已采纳同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
kafka拉取不到数据 java kafka 分布式有问必答
2022-02-16 19:32

回答 4 已采纳重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
Springboot集成kafka，应用很卡，消费很慢 java kafka spring boot
2022-10-25 09:26

回答 5 已采纳感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
Kafka消费者之Offset、重复消费、消费者事务及消息积压
2022-11-13 23:06

--只因--的博客 _consumer_offsets 主题里面采用，。每隔一段时间，kafka 内部会，也就是每个 group.id+topic+分区号就。
kafka可以生产无法消费的问题 java kafka
2022-06-11 10:41

回答 1 已采纳给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
flink消费kafka flink java kafka 有问必答
2021-07-02 11:07

回答 2 已采纳对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说，你只需要消费下一条就行了。至于偏移量，你第一次消费的时候，是要发送偏移的，这个你消费者要本地
Kafka消费者消费信息经常接收不到 java
2022-12-21 00:45

回答 1 已采纳这篇博客也许可以解决你的问题👉 ：kafka消费者从kafka读取信息
Java代码实现kafka的消息生产与消费
2022-10-16 23:19

Fairy要carry的博客 kafka本地线程默认会创建一个缓冲区，用来存放发送的数据（先放到缓冲区，当到达16k就进行发送）ack=0：生产者只需要把消息给到broker，而不需要到partition中kafka就会把ack返回给生产者，速度较快容易丢消息。...
kafka怎么获取之前的offset java linux
2020-04-28 14:06

回答 1 已采纳 kafka消费是可以指定offset的，你手动指定一个不就好了？多个生产者同时发送数据，你是要保证按照发送的顺序一一写到数据库中么？这样子的话可以只给当前topic，设置一个分区就行了不知道我
kafka中的消费拦截器 flink java kafka
2021-07-05 16:53

回答 1 已采纳 value的值为[B@1e1e585b这个明显是序列化后的Bytes字节类型嘛你反序列化成string就ok了
spark structured steaming与kafka集成offset管理方式 kafka spark
2023-01-31 14:43

回答 2 已采纳 Spark Structured Streaming 集成 Kafka 的 offset 管理方式有如下几种：利用 Spark checkpoint 文件提交 offset 给 Kafka常用的方案
临时解决kafka某分区offset不更新问题--重置group的offset
2020-11-09 20:42

hooyang的博客 kafka0.10.1.0之后版本版本： 1、查询到topic:FIMS offset的最小值 ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list XXX.XXX.XXX.XXX:9092 --topic FIMS --time -2 2、offset的最大值： ./kafka-...
flink消费kafka数据延迟 flink postgresql scala 有问必答
2022-01-28 09:47

回答 1 已采纳那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
Java整合kafka实现消费数据存入数据库
2022-08-24 11:41

唯空城的博客下面方法中除了创建【KafkaConsumer】的构造函数以外，还添加了订阅方法【subscribe】、消费消息方法【pool】、手动提交方法【commitSync】。然后线程运行时开始消费kafka，如果有返回值，则做进一步处理，其中用到...
Kafka处理数据超时导致Offset回滚，重复消费
2022-08-23 13:39

云康的博客 Kafka consumer重复消费
没有解决我的问题, 去提问

悬赏问题

¥15 基于卷积神经网络的声纹识别
¥15 Python中的request，如何使用ssr节点，通过代理requests网页。本人在泰国，需要用大陆ip才能玩网页游戏，合法合规。
¥100 为什么这个恒流源电路不能恒流？
¥15 有偿求跨组件数据流路径图
¥15 写一个方法checkPerson，入参实体类Person，出参布尔值
¥15 我想咨询一下路面纹理三维点云数据处理的一些问题，上传的坐标文件里是怎么对无序点进行编号的，以及xy坐标在处理的时候是进行整体模型分片处理的吗
¥15 CSAPPattacklab
¥15 一直显示正在等待HID—ISP
¥15 Python turtle 画图
¥15 stm32开发clion时遇到的编译问题

kafka事务消费offset不更新

2条回答 默认 最新

悬赏问题

2条回答默认最新