私はグーグルでカフカのドキュメントを読んでいましたが、コンシューマオフセットの最大値と最大値の後にオフセットラップアラウンドがあるかどうかはわかりませんでした。 オフセットはInt64値なので、最大値は0xFFFFFFFFFFFFFFFFです。 ラップアラウンドがある場合、カフカはどのようにこの状況を処理しますか?カフカ消費者オフセット最大値?
7
A
答えて
17
このpostによると、オフセットをリセットしないで見てください。
この時点では、オフセットをロールバックしません。オフセットは長いので、 は本当に長い時間続くことができます。 1TBを1日に書くと、約400万日の間に に行くことができます。
さらに、いつでもより多くのパーティションを使用できます(各パーティションには、独自の オフセットがあります)。
ルチアーノが言ったように、おそらく心配する価値はありません。
2
これは本当に「処理された」とは思われません。しかし、オフセットは、パーティションごとであることを考慮に入れて、我々がおよそ:)
を心配しないべきものであると思われるhttp://search-hadoop.com/m/uyzND1uRn8D1sSH322/rollover/v=threaded
関連する問題
- 1. カフカ消費者シェルスクリプト
- 2. カフカ - 消費者。 commitAsync
- 3. カフカ消費者ポーリングタイムアウト
- 4. 雲のカフカ消費者
- 5. カフカ消費者行動
- 6. カフカ消費者 - JMXプロパティ
- 7. カフカの消費者オフセットを決定する要因は?
- 8. カフカの消費者オフセットをリセットする0.10
- 9. カフカ10.2新しい消費者対古い消費者
- 10. カフカ消費者がデータを消費しない
- 11. カフカ0.9:カフカはカフカの消費者の私の読書から
- 12. カフカの消費者のエラーノードの障害
- 13. カフカの消費者からスパークストリーミング
- 14. 複数話題のカフカ消費者
- 15. カフカ消費者団体の問題
- 16. 春の統合カフカは:消費者
- 17. カフカ消費者スレッド安全性
- 18. カフカ - 異なる速度の消費者
- 19. マシン/プロセス間でカフカの消費者を拡大する
- 20. カフカ消費者はサーバー内のレコードを消費していません
- 21. なぜカフカの消費者は、消費に時間がかかりますか?
- 22. Kafka10消費者対Kafka8消費者
- 23. カフカ複数トピックの消費
- 24. AWSのカフカ消費問題
- 25. 消費者グループコーディネーターと消費者グループリーダーの間のカフカの違いは何ですか?
- 26. 別の消費者が放棄した時点からカフカ消費者を開始する
- 27. カフカ消費者が最も近いブローカーを選択する方法は?
- 28. カフカ消費者は最新のメッセージから始まっていません
- 29. 高レベルのカフカ消費者を一時停止する
- 30. カフカ消費者を一時停止する方法は?
である。ちょうどY2Kのように:) – Nick