私のチームは最近、プロジェクトに使用する別のメッセージ ブローカーを検討していました。最終的に Apache Pulsar を選択しましたが、他のもの (Kafka) にも適用されます。私たちの要件は、送信されたメッセージの総数と、課金目的で各サブスクライバーに送信されたバイト数を追跡することです。
メトリクスのドキュメントを読んでいて、Pulsar がこれを追跡していないことに驚きました。Kafka をチェックしたところ、結果は同じでした。この件に関する私の理解は最小限なので、これはある種のアンチパターンですか? このようなカウンター値は決して下がらず、私たちのユースケースではリセットされるべきではないことを理解しています。これにより、(特定の) オーバーフローが発生する可能性があります。しかし、私にとってこれは、Prometheus のヒストグラム (Pulsar で使用されるメトリクス形式) のようなものを使用することで解決できます。私は実際にそのような機能を実装することを考えていますが、私は間違っていますか?私たちの目的のためのより良い解決策はありますか?