The project i am working on has to route messages to kafka topics based on the field 'topic' in the message. When this routing fails for some reason such as the 'topic' field is empty I send messages to a dead letter topic for manual fix. Is there a possibility to retrieve a single or list of messages so that they can be fixed manually?
Found that I have to write another @KafkaListner, which listens to dead-letter-topic and processes the message. Here the problem is I need to fix them manually.