This space is reserved for the development of Apache Kafka consumer. We have written our custom Consumer PcfMultiThreadConsumer which listens to every topic configured in pcf.properties and executes a task (as Bash script) on receiving a message.