kafka offset 設置

consumer.seek(topic_partition, offset_value) consumer.commit() from: http://stackoverf ...