Instead of sending a push message by submitting a task to

 
notificationRouter.submit(pushApplication, message);

Create a Kafka producer that will send the info to a new topic.

See send method