ag_kafka_utils
