問題タブ [apache-pulsar]
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.
go - Pulsar プロデューサーで「SendAsync」メソッドを使用すると、「メッセージの予期しない送信受信を受け取りました」という警告が表示される
複数のプロデューサーを介してメッセージを発行する Pulsar トピックがあります。これらのプロデューサーは単なるゴルーチンでありSendAsync
、プロデューサーでメソッドを使用してメッセージを送信していますが、Got unexpected send receipt for message
警告が表示され続けます。クライアントのライブラリ コード (Pulsar の golang クライアント) を調べたところ、この警告は、プロデューサーがこのマップでリスナーとして登録されていない場合にのみ表示されることがわかりましたmap[uint64]ConnectionListener
。しかし、プロデューサーがリスナーとして登録されていない場合、どうすれば公開できますか?