問題タブ [strimzi]

kube -prometheus-stack helm チャートを使用してStrimziを監視しようとしています。Strimziの公式ドキュメントのチュートリアルに従ってセットアップしました。このチュートリアルでは、両方とも Podmonitors と Prometheus 構成を使用していくつかのメトリックを取得します。しかし、一部のメトリクスには Podmonitor を設定し、他のメトリクスには prometheus.prometheusSpec.additionalScrapeConfigs にジョブを追加する必要がある理由がよくわかりません。誰かが私に違いを説明できますか？

onを使用して別のクラスターからデータをコピーする Kafka クラスター ( Strimzi CRD を使用) をデプロイしています。問題は、Kafka を再起動するとデータが失われることです。永続的なボリューム クレームを使用しているため (他のすべてのケースでうまくいきました)、どこに問題があるのか​​よくわかりません。KafkaMirrorMakerAzure

Strimziのドキュメントを調べていると、次のような文が見つかりました。

「Srimzi には、StorageClass を介してプロビジョニングされたブロック ストレージが必要です。ストレージのファイル システム フォーマットは、XFS または EXT4 である必要があります。3 種類のデータ ストレージがサポートされています。」[5.3 のすぐ下]。

問題は、ストレージ クラスのファイル システムが間違っていることでしょうか? さまざまな Azure ストレージ クラスが使用しているファイル システムがわかりません。これが問題を引き起こす可能性があるかどうか（またはXFS/EXT4誰もが使用する標準であるかどうか）は誰にもわかりませんか？

ログに関連情報が見つかりません。誰かがここで見たいのは、私のKafkaストレージを定義する方法ですdefault-hdd-reatin。

ご存知のように、メッセージの送信方法には同期と非同期の 2 種類があります。

同期モードでコーディングすると、コードは次のようになります。

Kafka ドキュメントhttps://kafka.apache.org/10/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html#send-org.apache.kafka.clients.producer.ProducerRecord-から読み取ると、次のように定義されます。続く：

つまり、基本的に send() メソッドは Futher を返し、この Future に .get() を使用すると、同期動作になります。

私の質問は、定義から、例外定義が表示されないことです。同期 send() で例外をキャプチャする方法は? 例外は定義されていないようです。誰かがそれを明確にするのを助けることができますか?