connect gearpump with Kafka

Please use private val if possible