2016-04-08 8 views
0

kafka 0.8から0.9にアップグレードしようとしていましたが、kafkaの消費者オフセット管理を0.9の一部としてリリースしたいと考えています。これまではオフセットをデータベースに保存していましたが、カスタムコンシューマーにはデータベースのオフセットをチェックし、カフカからのメッセージを取得しました。kafkaはローカルデータベースからkafkaへの移行をオフセットします

どのようにこれらのオフセットをkafkaに移行できますか?私はkafkaについて、zookeeperからkafkaへの移行をオフセットしましたが、これについては何も見つかりませんでした。

答えて

0

あなたは手動でOffsetCommitRequestをkafkaに送信して現在のオフセットを設定し、新しいコンシューマの使用を開始できます。 kafka wikiたとえば

関連する問題