new version of kafka-camus consumer, with new features