kafka的offset值一直不变，可以往里面写数据
会是什么原因呢
手动改变offset的值是可以消费数据的
kafka数据可以写入数据，消费不可数据
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
1条回答
- 2022-01-28 09:47回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
- 2022-02-16 19:32回答 4 已采纳 重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
- 2022-07-13 20:33回答 3 已采纳 restclient异常，先看看taskmanager和jobmanager是否正常，然后你可以在jobmanager的节点上访问webUI查看job状态，又或者直接查看宿主机上的日志排查问题
- 2021-01-01 17:26往事随风_h的博客 消费者数据不丢失二、不重复消费数据 一、不丢失数据 1.生产者数据不丢失 同步模式：配置=1（只有Leader收到，-1所有副本成功，0不等待）。leader partition挂了，数据就会丢失。 解决：设置为-1保证produce写入...
- 2021-04-20 10:49回答 3 已采纳 https://gewu.pcwanli.com/front/article/10619.html
- 2023-02-02 16:54回答 4 已采纳 ''该回答引用ChatGPT''如对你的问题有帮助，请点击右侧采纳即可！没有使用ZooKeeper的话，一种可行的方案是利用ClickHouse的复制功能实现双机数据同步。ClickHouse的复制功
- 2022-06-11 10:41回答 1 已采纳 给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
- 2021-01-20 12:52生产者可以进行有关配置，使得不一定等到数据认为是已提交的之后，才进行下一轮的投递，这是在可用性和一致性的之间的平衡 分区副本复制方式和同步条件： 每个分区所在的broker需要向分区首领所在的broker每6s（可...
- 2021-07-22 08:54回答 4 已采纳 用@Scheduledhttps://blog.csdn.net/limingcai168/article/details/103394041
- 2022-08-23 10:01回答 1 已采纳 同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
- 2021-07-27 10:36回答 1 已采纳 kafka调用send方法发送数据后 会返回一个ListenableFuture 这个ListenableFuture可以添加callback进行监听d
- 2019-01-12 20:31从0到1哦的博客 一、不丢失数据 1.生产者数据不丢失 同步模式：配置=1（只有Leader收到，-1所有副本成功，0不等待）。leader partition挂了，数据就会丢失。 解决：设置为-1保证produce写入所有副本算成功 producer.type=sync...
- 2023-01-14 04:00回答 1 已采纳 你要记录你的消费的offset从指定offset开始消费。如果有过消费记录的话。如果不指定就从eariest开始消费
- 2022-07-04 08:42程序员 Harry的博客 序列与反序列化 kafka 数据 Flink Kafka Consumer 需要知道如何将 Kafka 中的二进制数据转换为 Java 或者 Scala 对象。KafkaDeserializationSchema 允许用户指定这样的 schema，每条 Kafka 中的消息会反序列化。 ...
- 2020-04-11 01:32weixin_39120411的博客 不管是把 Kafka 作为消息队列、消息总线还是数据存储平台来使用，总是需要有一个可以 往 Kafka 写入数据的生产者和一个可以从 Kafka 读取数据的消费者，或者一个兼具两种角 色的应用程序。 例如，在一个信用卡事务...
- 没有解决我的问题, 去提问
