Customized Apache Kafka Class