Since Kafka extension is registering the process listener in onDeploy method and singleton strategy initiliaze listener just once and before this method is invoked, the listener is not there when onMessage is fired, hence the record is not published to Kafka.

This will be solved by registering the listener on default deployment descriptor for kafka server extension, rather than in onDeploy method.