Install via Go from source: Set offset for consumer group dispatcher consuming from topic mqtt.messages.incoming to latest for all partitions kaf group commit dispatcher -t mqtt.messages.incoming ...