Apache Kafka
の簡易ヘルスチェッカーが必要です。 Yahoo Kafka Manager
のような大規模で複雑なものはほしくありません。基本的には、トピックが健康であるかどうか、消費者が健康であるかどうかをチェックしたいと思います。基本的なカフカトピック可用性チェッカー
最初のアイデアは、別のheart-beat
トピックを作成し、定期的にメッセージを送受信して、可用性と待ち時間を確認することでした。
2番目の考えは、Apache Zookeeper
からすべてのデータを読み取ることです。私はすべてのブローカー、パーティション、トピックなどをZKから得ることができますが、ZKが障害検出情報のようなものを提供できるかどうかはわかりません。
私が言ったように、私は私のアプリの健康チェッカーで使用できる単純なものが必要です。