apache-kafka - spring boot kafka消费者进程事件21次
问题描述
我在我的项目中使用社区版融合 kafka 进行开发。我的 spring boot kafka 消费者总是处理每个事件消息 21 次。无论事件处理是成功还是失败。我无法找到可以在哪里添加这个值,即 kafka 消费者应该处理该事件多少次。我的理解是,如果一个事件被成功处理,那么消费者不应该再次尝试处理它,应该有预设的尝试定义,如果事件处理失败,消费者将尝试处理事件。注意-我有 spring boot kafka 消费者,那个过程事件并将响应发送回 akfka 服务器到不同的主题。
解决方案
推荐阅读
- apache-nifi - Nifi流文件中如何删除流文件属性?
- tensorflow - 直接导入 Keras 还是通过 TensorFlow 导入?我应该卸载其中一个吗?
- javascript - ASP.NET Core Fetch POST FormData() application/x-www-form-urlencoded
- laravel-5 - Laravel 5.6 模拟 Guzzle 响应
- sql - 解码函数 SQL
- sql-server - 用于快速添加的存储过程
- graylog2 - Graylog 2.3.2 API 令牌:没有可用于访问令牌的配置
- javascript - 如何在纯 JavaScript 的帮助下对表格进行排序并重新生成它
- javascript - 试图在一次调用中获取 2 个复选框数据以创建 zip 文件。我应该如何在一次服务调用中传递对象中的数组?
- java - 将 Spring 分页应用于动态创建的查询