kafka_helpers
