at java.util.concurrent.FutureTask.report(FutureTask.java:122) ~[na:1.8.0_111-internal] at java.util.concurrent.FutureTask.get ...
Scenario: I have written a Kafka streams application which consumes data from an input topic, transforms data and loads into ...