問題タブ [kafka-topic]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
apache-kafka - Spark Structured Streaming - オフセットを 2 回書き込むことは可能ですか
Spark 構造化ストリーミングを使用して、kafka トピックからデータを消費し、そのデータを別の kafka シンクに書き込みます。
オフセットを2回保存したい-トピックから読み取ってオフセットをかき混ぜるときに1回。第二に、データを出力シンクに書き込み、オフセットを書き込むとき。これは、チェックポイント ディレクトリの場所を指定することで可能になります。
トピックのサブスクライブ中に消費されたオフセットを書き込むことは可能ですか。
java - トピック用に新しいパーティションを作成すると、Kafka ではどうなりますか?
オンラインでいくつかのガイドを読んだところ、キーの順序付けを使用している場合、新しいパーティションが最終的にその順序付けを破ってしまうことがわかりました。これは本当に起こることですか?