我为retry主题配置提供了一个bean:public RetryTopicConfiguration kafkaRetryTopicConfig(...) { .create(template);我还为重试主题名称提供者工厂定义了一个bean:
// Need this because it is not just retry/DLT它正在处理kafkaRetryT
我有一个用Java编写的卡夫卡应用程序,配置了DeadLetterPublishingRecorer:public DeadLetterPublishingRecoverer dltPublisherMyAppexception) -> new TopicPartition(record.topic() + "Error", record.partition()), objectMapper);如您所见,DLTCreateMyObjectRequest
public class CreateMy
我使用Spring-Kafka2.8.6和重试RetryTopicConfiguration。 topics = "...@Header(KafkaHeaders.DELIVERY_ATTEMPT) final int deliveryAttempt) {我已经设置了常见的错误处理程序factory.getContainerProperties().setDeliveryAttemptHeader(true);
ret
我有个KafkaListener在用卡夫卡的阿夫罗留言。如果处理使用的消息的逻辑抛出异常,则错误处理程序将将消息发送到DLT。我希望以JSON的形式发送该消息,并忽略任何模式注册表内容。我遇到了问题,因为如果我尝试使用JSON序列化程序,它就无法序列化,因为它是一个Avro对象。错误处理程序 public DefaultErrorHandler e