基于不同情况重试发送Spring Kafka模板
我使用SpringKafka的KafkaTemplate以异步方式发送消息，并使用回调进行正确的错误处理。
此外，我已将 Kafka 生产者配置为具有最大重试次数 （MAX_INTEGER）。
然而，可能有一些与avro序列化相关的错误，但对于那些重试没有帮助。那么，我如何在不重试的情况下逃避这些错误，但对于其他与代理相关的问题，我想重试？
共有1个答案
序列化异常将在发送消息之前发生，因此retry属性在这种情况下无关紧要；它仅在实际发送消息时适用。
-
我正在建立一个应用程序，用户将把他们的测试和作业和任何东西。我想知道我的应用程序是否有可能在测试前一周和一天发出通知？ 我看到的到处都是firebase通知和push通知。 我不想要这些在线通知，我将需要应用程序发送他们自己离线。这可能吗？
-
我正在重新学习Hibernate和JPA。我正在使用Spring Boot，Gradle和Postgres为我的环境。我有一组访问Postgres数据库的域对象。两个对象不使用注释，使用一个JDBCTemplate类进行数据库操作。另一组域对象使用JPA注释。JPA对象集具有使用JPA注释映射的关系。当我运行单元测试来检查JDBC模板对象的数据库实体时，一切都很好。当我检查数据库时，我发现使用注释
-
此方法的输入为“9876548” 我不要结尾的“9876548”。 （叠加流格式不会全部 实现一个递归方法 printDigits，该方法将整数 num 作为参数，并以相反的顺序打印其数字，每行一个数字。 谢谢大家的帮助！
-
本文向大家介绍基于Python模拟浏览器发送http请求，包括了基于Python模拟浏览器发送http请求的使用技巧和注意事项，需要的朋友参考一下 1.使用 urllib2 实现 2.使用 requests 模块 （1）.get请求 （2）.post请求 （3）.使用session对象的写法 3.其他的一些请求方式 >>> r = requests.put("http://httpbin.org/
-
我试图使用一个类型族来生成依赖于某个类型级别自然数的约束。下面是这样一个函数： 然后我有一个函数，它有这个约束。 当我试图在模式匹配中使用这个函数时，我的类型族应该产生这个约束，ghc说它不能推导出约束 下面是一个例子： 它会产生错误
-
这将产生以下错误。 不能赋值给引用或变量！ Googling会导致很多关于同一主题的点击--组件中的变量和生成的标记的ID之间有冲突。在我看来，这里不是这样。我将组件中唯一的字段重命名为记录，甚至没有看到任何ID被分配给生成的标记。 它告诉我的很少。但这说明了什么，对吧？ 组件代码如下所示。