問題タブ [kafka-rest]

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.

0 投票する
1 に答える
122 参照

apache-kafka - kafka rest proxy API は取得したいレコードの数を指定します

kafka rest proxyは、取得するレコードの数を指定します。

GET /consumers/(string:group_name)/instances/(string:instance)/records

サブスクライブ/割り当て API のいずれかを使用して、指定されたトピックまたはパーティションのデータを取得します。

この API は、トピックからレコードを取得するために使用されます。取得したいレコード数を指定する便利なパラメーターはありますか。

たとえば、特定のオフセットから 10 レコードを取得したいとします。この API には、 timeoutmax_bytes
の 2 つのクエリ パラメータしかありません。limit_numのようなパラメーターはありません。

POST /consumers/(string:group_name)/instances/(string:instance)/positions

コンシューマーがフェッチする次のレコード セットに使用するフェッチ オフセットをオーバーライドします。

この API を使用して、取得したい開始オフセットを設定できます。