Commit b8652b1c authored by Prasanna Dumpala's avatar Prasanna Dumpala

Update Consumer.java with dlq

parent c4583ca6
......@@ -15,6 +15,8 @@ public class Consumer {
@StreamListener(Processor.INPUT)
public void consumeProductDetails(Product productDetails) {
LOGGER.info("Consuming the product details: {}", productDetails);
String a = null;
a.substring(0, 3);// to interrupt the consumer, then the data will be routed to dlq topic
}
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment