Заменить ответ FOR Кафки ⇐ JAVA

[Anonymous]

Я пытаюсь преобразовать сообщение об ошибке из списка, чтобы не отправлять сообщение в DLQ, а возвращать тему с некоторой минимальной информацией. Как я могу это сделать?
У меня есть метод прослушивателя, использующий @RetryableTopic, который работает нормально, но я могу использовать информацию только тогда, когда она отправляется в dlq. Мне не нужен dlq, а нужно отправлять себе информацию по другой теме, когда все повторные попытки не увенчались успехом. Может ли кто-нибудь мне помочь?
@RetryableTopic(
attempts = 2,
backoff = @Backoff(delay = 2000L),
sameIntervalTopicReuseStrategy = SameIntervalTopicReuseStrategy.SINGLE_TOPIC,
kafkaTemplate = "requestProducerTemplate",
include = {RetryableException.class}
)
@KafkaListener(
topics = "listener",
groupId = "listener-group-id",
containerFactory = "myListenerContainerFactory"
)
public void listener(MyObject request) throws RetryableException {
throw new RetryableException("Retryable Failure");
}
// this is the method that I want to send back the response
private void transformAndRespons(MyObject request) {
myKafkaProducerService.sendError("Error: " + request.getId());
}


Подробнее здесь: https://stackoverflow.com/questions/784 ... e-of-kafka