Kafka Service will implement this listener interface and get loaded in BF starter. https://github.com/cngupte123/blueflood/blob/f22de66bc3d1a7515da7236075f8e0749f07dbc6/blueflood-kafka/src/main/java/com/rackspacecloud/blueflood/kafkaproducer/KafkaService.java#L32