我需要识别数据库连接失败异常与其他异常，并在我的kafka侦听器错误处理程序中进行相应的处理。由于Spring Data JPA中的所有内容都被转换为DataAcccessException，我只是想知道当应用程序运行时发生连接故障时会抛出什么异常。工作环境: Spring boot 2.x、Spring data jpa、spring-
浏览 2提问于2019-02-20得票数 1
我刚开始使用spring-kafka 2.6.4。我创建了按批轮询消息的消费者工厂： @Bean kafkaListenerContainerFactoryfactory.getContainerProperties().setAckMode(ContainerProperties.AckMode.BATCH);} 现在，我想定义适当<em
浏览 71提问于2021-01-19得票数 1
回答已采纳
我在使用Spring Cloud Stream编写的Kafka Stream作业中遇到了一个场景，producer因异常而失败。在kafka流中检查，有一个配置来处理相同的问题：default.production.exception.handler
在spring云流中找不到后续处理程序。请帮帮忙。提前谢谢。Spring boot版本：2.2.4.RELEASE
浏览 2提问于2020-03-11得票数 0
我试图在Spring kafa中实现错误处理。在我的Kafka侦听器中，我抛出一个运行时异常，如下所示：
@KafkaListener(topics= "Kafka-springboot-example", groupId="group-employee-jsonspring.kafka.producer.value-serializer=org.springframework.
浏览 1提问于2020-04-05得票数 1
回答已采纳
未能创建主题2021-04-27T08:48:12.806690772Z org.apache.kafka.common.errors.PolicyViolationException:服务无法处理请求有关异常类型和正确异常处理的详细信息，请参阅。
在使用Spring引导、事件中心和Kafka时，我正面临上述问题。下面是我所关注的依赖关系。<groupId>org.apache.kafka<
浏览 5提问于2021-04-27得票数 0
我使用spring引导版本2.5.3，spring stream-binder-kafka-stream版本3.1.3和kafka-客户端版本2.8.0。我想使用REPLACE_THREAD选项来处理kafka流中的不明确异常处理程序。
浏览 8提问于2021-08-13得票数 0
回答已采纳
我目前正在使用Spring来使用来自主题的消息以及@Retry of Spring。因此，基本上，我正在重新尝试处理消费者的信息，以防出现错误。但是，在这样做时，我希望避免KafkaMessageListenerContainer抛出的异常消息。相反，我想显示一条自定义消息。我尝试在ConcurrentKafkaListenerContainerFactory中添加一个错误处理程序，但是在这样做时，不会调用我的重试。
浏览 14提问于2020-06-24得票数 0
我正在为spring kafka streams应用程序的定制而苦苦挣扎。我一直在尝试在我的KStreams中配置处理未捕获(运行时异常)。参考文档https://docs.spring.io/spring-cloud-stream-binder-kafka/docs/3.1.0/reference/html/spring</em
浏览 65提问于2021-01-14得票数 0
1回答
我使用的是spring-kafka 2.2.6。我用过SeekToCurrentErrorHandler和ErrorHandlingDeserializer2。有没有办法跳过验证错误(由Spring中的Validator实现捕获)和消息转换错误的重试？所有错误都被容器错误处理程序(即SeeToCurrentErrorHandler )截获。我应该重写SeeToCurrentErrorHandler的handle方法吗？
浏览 29提问于2020-02-12得票数 0
回答已采纳
1回答
我希望批处理侦听器在记录失败之前提交偏移量，记录失败的记录，然后从失败记录后的第一个偏移量开始检索新批处理。我的当前方法处理侦听器代码中抛出的异常，方法是按我的意愿抛出一个由BatchListenerFailedException处理的RecoveringBatchErrorHandler。但是，我想以这种方式处理所有异常；也就是说，侦听器引发的
浏览 13提问于2021-09-04得票数 0
回答已采纳
1回答
对于我的卡夫卡批次消费者，有两种情况我想要处理。
侦听器中发生的异常。由于我正在对批处理应用一些流操作(过滤和分组等)，因此很难确切地知道批处理中哪些记录失败。因此，对我来说，只要重试整个批，并且如果达到重试极限，将整个批处理发送到DLQ，这是更简单和可以接受的。现在，我仍然需要处理场景1(反序列
浏览 1提问于2021-06-29得票数 0
我使用spring-cloud-stream-kafka-binder-3.0.4批量消费消息，消费后将消息转换为object，但得到上述异常。=falsespring.cloud.stream.kafka.bindings.activity-input-channel.consumer.start
浏览 64提问于2021-09-17得票数 0
回答已采纳
几周前，我的项目被更新为使用Kafka 3.2.1，而不是使用Spring 2.7.3 (3.1.1)附带的项目。我们进行这一升级是为了避免Kafka流中的一个问题--非法状态和参数异常不会在未被处理的异常处理程序中结束。在消费者方面，我们也转移到合作粘性分配。同时，我们启动了一些弹性测试，并且开始出现使用Kafka批处理侦听器
浏览 8提问于2022-09-01得票数 1
回答已采纳
我正在尝试使用spring-kafka版本2.3.0.M2库编写kafka consumer。为了处理运行时错误，我使用带有DeadLetterPublishingRecoverer的SeekToCurrentErrorHandler.class作为我的恢复器。只有当我的消费者代码抛出异常时，它才能正常工作，但当无法反序列化消息时，它就会失败。我试着自己实现ErrorHandler，并取得了成功，但使用这种方法，我自己最终还是编写了DLT代码来
浏览 56提问于2019-06-24得票数 3
回答已采纳
1回答
在异常的应用程序终止并重新启动之后，我的应用程序开始接收来自Kafka队列的旧的、已经处理过的消息。spring.kafka.bootstrap-servers=${kafka.host}:${kafka.port}
spring.kafka.consumer.auto-offset
浏览 0提问于2018-07-08得票数 4
回答已采纳
我使用spring-kafka来使用SpringBoot1.5.16实现流应用程序。我们使用的spring-kafka版本是1.3.8 version。我正在搜索一个方法来关闭引导应用程序，以防错误终止所有与withKafka流相关的线程。我发现在中有可能注册一个句柄来处理不明确的异常。方法为。我看到这个方法是在spring-kafka中以KStreamBuilderFactory
浏览 4提问于2020-01-17得票数 1
回答已采纳
这是关于升级生产中的现有代码库，这些代码库使用来自kafka-clients，kafka-streams，spring-kafka 2.4.0到2.6.x的窗口，并将spring-boot-starter-parent2.2.2.RELEASE升级到2.3.x，因为2.2与kafka-streams 2.6不兼容。streamsBuilder.build();
浏览 20提问于2021-05-15得票数 2
1回答
在我的Kafka Listener被击中之前，我得到了一堆反序列化的失败。我正在研究Gary Russel构建的东西，但在让它工作时遇到了问题。我所有的东西都是通过属性文件配置的。spring.kafka.consumer.properties.spring.deserializer.value.delegate.class=io.confluent.kafka.serializers.KafkaAvroDeserializer我<e
浏览 21提问于2021-01-07得票数 0
回答已采纳
使用Spring cloud Stream Kafka监听器从kafka主题中读取消息，并在异常情况下将消息发送到死信队列，配置属性 spring.cloud.stream.kafka.bindings.input.consumer.enable-dlq=true
spring.cloud.stream.kafka.bindings.input.consumer.dlq-name=book_error 我可以向DLQ发送消息。我无法读取嵌入在头文件<e
浏览 15提问于2020-01-26得票数 1
云服务器
ICP备案
对象存储
即时通信 IM
云直播
腾讯云开发者
