memobase-kafka-utils API