この記事は機械翻訳のミラー記事です。元の記事にジャンプするにはこちらをクリックしてください。
建築家
建築家
リスト
放送
茶屋
インテリジェントAI会話
.NETキャリア&テクニカルカレッジ
ちっちゃいなクズブログ
この版
利用者
Architect_Programmer_Code農業ネットワーク
»
建築家
›
プログラミング
›
その他の番組編成
›
カフカは手動でオフセットオフセットを設定します
眺める:
9714
|
答える:
0
カフカは手動でオフセットオフセットを設定します
[リンクをコピー]
クズども
掲載地 2021/05/08 17:12:09
|
|
|
|
トピックの詳細を見る
ログインが見えます。
復習:
.NET/C#メッセージキュー用のKafka操作[ソースコード付き]
https://www.itsvse.com/thread-9619-1-1.html
前提条件:
関連するすべての消費者サービスは停止されなければなりません
。
次のコマンドを実行するだけです:
まず、指定された消費者グループ情報で使われているトピックオフセットオフセットを確認します。
ログインが見えます。
カレントオフセットと対数エンドオフセットもラグを持ち、それぞれ現在のオフセット、エンドオフセット、ラギングオフセットがあります。
今やラグは10546、current-offset=10544、log-end-offset=21090であることが明らかで、未消費のものが10546個あることを示しています
電流オフセット
オフセットまでの現在の消費は10544であり、これは10544が消費されたと理解できます。
対数-終了-オフセット
:は合計21,090件のレコードと理解できます。
LAG
これは未使用レコードの数として理解できます。
オフセットのオフセットを手動で設定します
ログインが見えます。
グループの消費量を再度確認します。
ログインが見えます。
消費されないメッセージは3つだけです。下の図のようにコンシューマープログラムを開いて実行します。
残りの3メッセージのみが消費され、手動でオフセット調整が成功しました。
(終わり)
先の:
Core(8)のSwagger UIのデフォルトパラメータの穴 ASP.NET。
次に:
.NET CoreはRedis Lua(ソースコード付き)に基づく分散ロックを実装しています
関連記事
•
まとめ:RabbitMQはカスタムスイッチとキューを作成します
•
RabbitMQ:誰がキューと交換を作るのか
•
【実戦】カフカパラメータ調整は、メッセージ本体が大きすぎる問題を解決します
•
Spring Boot Kafkaが再起動して古いデータを破棄します
•
Spring BootはKafkaのトピックまたはGroupIDを動的に設定します
•
CentOS 7の下で、カフカはしばしばソリューションを停止します
•
カフカのauto.offset.reset値について詳しく説明しています
•
KafkaのWindowsシステムは一定時間動作すると停止します
•
Windows Kafkaエラー ログのクリーンアップに失敗__consumer_offsets
•
KafkaがJMXリモートモニタリングを設定する
閲覧したセクション
Memcached/Redis
ジャワ
.Net/C#
免責事項:
Code Farmer Networkが発行するすべてのソフトウェア、プログラミング資料、記事は学習および研究目的のみを目的としています。 上記の内容は商業的または違法な目的で使用されてはならず、そうでなければ利用者はすべての結果を負うことになります。 このサイトの情報はインターネットからのものであり、著作権紛争はこのサイトとは関係ありません。 ダウンロード後24時間以内に上記の内容を完全にパソコンから削除してください。 もしこのプログラムを気に入ったら、正規のソフトウェアを支持し、登録を購入し、より良い本物のサービスを受けてください。 もし侵害があれば、メールでご連絡ください。
Mail To:help@itsvse.com