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.

[send method|aerogear-unifiedpush-server/jaxrs/src/main/java/org/jboss/aerogear/unifiedpush/rest/sender/PushNotificationSenderEndpoint.java]