update for new kafka-clj