如何在错误处理程序中将SpringKafka偏移到下一个？
我使用的是spring data 1.5.8和Kafka的手动确认模式。只有一个简单的ErrorHandler接口，handle方法有参数exception和consumerRecord，但是如果json无法反序列化时抛出异常，我如何将偏移量设置为next？我需要省略这条信息，否则消费者会被卡在那里
spring data 2.0引入ConsumerRawareErrorHandler，唯一的方法就是更新spring版本？
共有1个答案
是的。您需要升级。当前版本是2 4.0或2.3.4。
-
我能够使用ErrorDesrializationHandler成功处理反序列化错误，但当我重新启动我的消费者时，它再次开始重新处理由于反序列化而导致的所有失败消息。 由于反序列化异常无法到达Kafka Listener，如何确认并提交偏移量？ 谢谢。 我正在使用的自定义错误处理程序： }
-
在我的侦听器中，在使用消息后，如果发生任何异常，我将抛出一个异常。如果它成功了，那么我承认。但是，即使抛出异常，偏移量也不会后退。i、 e重试没有按预期进行。错误事件不会再次出现。 此外，我发现我没有消费所有预期的消息。我做错什么了吗？ 监听器类 我正在做
-
我想开始最新的抵消，而不是为旧的价值所困扰。是否有可能重置该组的偏移量？
-
我需要为以下有效日期创建。 我尝试了以下日期时间格式化程序，但在最近两个日期(和)中失败。 从到的所有日期都可以正常工作，但在尝试分析最近两个日期时，我得到一个: 线程“main”java.time.format.DateTimeParseException中出现异常：无法解析文本“2017-06-20T17:25:28.477777+0530”，在索引29处找到未解析的文本 用于解析我正在使用的
-
我正在尝试使用Dismissible（）从交易列表和应用程序屏幕中删除其中一个交易。但我得到了错误 deletetx只是我的main.dart文件中的一个函数，它删除事务并更改状态。