kafka_utils
tests
