2016-07-07 10 views
7

0.10では、seek()で特定の位置にオフセットをリセットすることができます。カフカの消費者オフセットをリセットする0.10

これはコマンドラインのutilですか?今のところそれはそうじゃない?

+2

名前とは異なり、Kafkaストリーム以外のアプリケーションには 'kafka-streams-application-reset'スクリプトを使用できます。$ KAFKA_HOME/bin/kafka-streams-application-reset.sh --zookeeper zk:2181 --application-id myGroupId - 入力 - トピックmyTopic' – Raf

+0

'kafka-streams-application-reset'は、最も早いオフセット位置にリセットされます。 _specific_の位置にリセットすることはできません – sworisbreathing

答えて

2

この目的のための単純なコマンドラインツール(https://github.com/serejja/kafka-offset-mgr)を実装しました。

お気軽に試してみてください。必要に応じて問題やPRを投稿してください。

+0

ありがとうございます!これは私が必要とするものです。 – Brandon

関連する問題