I am trying to build a simple kafka streams application that just needs to process a record (Assume it takes around 1-2 seconds) and then write it to an output topic, I have come up with the following, while the CompleteableFuture processes the records as expected (I am using this as to process the records concurrently as all the records are independent of each other). However, I unable to see anything on the output topic.