https://github.com/aerogear/aerogear-unifiedpush-server/tree/GSOC_2017_kafka/push/sender/src/main/java/org/jboss/aerogear/unifiedpush/message/kafka