add kafka-based scheduler. untested