Package io.factorhouse.kpow.key
Interface KeyStrategy
-
- All Known Implementing Classes:
ClientIdKeyStrategy,ClusterIdKeyStrategy
public interface KeyStrategyDefines the key strategy used by Kpow's streams agent.This interface specifies how metrics data should be keyed when writing to Kpow's internal snapshots topic.
Concrete Implementations
ClientIdKeyStrategy- Uses the client ID and application ID for keying, suitable for constrained environments.ClusterIdKeyStrategy- The recommended strategy that uses the Kafka cluster ID for keying, ideal for multi-cluster deployments.
- See Also:
ClientIdKeyStrategy,ClusterIdKeyStrategy
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description TaxongetTaxon(String clientId, String applicationId)Resolves the unique key for metric records based on the provided clientID and applicationID of the registered Kafka Streams application.
-
-
-
Method Detail
-
getTaxon
Taxon getTaxon(String clientId, String applicationId)
Resolves the unique key for metric records based on the provided clientID and applicationID of the registered Kafka Streams application.The resolved key, represented as a
Taxon, serves as the primary identifier for grouping and organizing metrics data in Kpow's snapshots topic. This enables Kpow to align the metrics with the correct Kafka Streams application in the UI.- Parameters:
clientId- The client ID of the registered streams application.applicationId- The application ID of the registered Kafka streams application.- Returns:
- The unique Taxon object representing the key.
-
-