ホームページ >バックエンド開発 >Golang >Convergence Kafka Go クライアントの「無効なレプリケーション係数」

Convergence Kafka Go クライアントの「無効なレプリケーション係数」

王林
王林転載
2024-02-14 10:30:09898ブラウズ

汇合 Kafka Go 客户端中的“无效复制因子”

php エディター Xigua は本日、Kafka Go クライアントの「無効なレプリケーション要素」に関する記事をお届けします。 Kafka は高性能でスケーラブルな分散ストリーム処理プラットフォームですが、Go は簡潔で効率的なプログラミング言語です。この記事では、Kafka Go クライアントで発生する「無効なレプリケーション係数」問題に焦点を当て、その原因と解決策を探り、読者がこの一般的な技術的課題をより深く理解し、対処できるように支援します。無効なレプリケーション要素はデータの不整合やパフォーマンスの低下を引き起こす可能性があるため、Kafka ユーザーがこの問題の対処方法を理解することが重要です。一緒に深く探っていきましょう!

質問の内容

私は Kafka を初めて使用し、プロジェクトを開始しようとしています。 docker-compose.yml に this

があります リーリー

次に、プロデューサーとコンシューマー、およびいくつかのモック トピックを使用して main.go ファイルを実行します。

リーリー

デフォルト値のコメントを解除すると、その値が影響を受けます。

そうしないと、コンソールにこのエラーが表示されます。

リーリー

kafka コンテナと Zookeeper コンテナが実行されています。

docker-compose.yml ファイルを変更しましたが、役に立ちませんでした。 Consumer.Events() が nil であることがわかりましたが、なぜこれが起こっているのかわかりません

回避策

コードをコピーしました。正しいですが、compose.yml でのみ問題が発生しています。 ADVERTISED_LISTENERS

を調整しました ### これの代わりに: ### リーリー ###これを使って:### リーリー

以上がConvergence Kafka Go クライアントの「無効なレプリケーション係数」の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

声明:
この記事はstackoverflow.comで複製されています。侵害がある場合は、admin@php.cn までご連絡ください。