Hi @Vadim Dzyuban, I'm facing the same issue - What is finally your recommendation/best practice in order to re-consume the whole kafka queue in a specific topic ? Should I change the kafka.consumer.group.id , then restart the flume agent with this specific setting: *.auto.offset.reset = earliest In advance, thank you. Best, Stephen ... View more