public class EngineInitializationContext
extends java.lang.Object
Constructor and Description |
---|
EngineInitializationContext(kafka.server.KafkaConfig kafkaConfig,
java.util.Map<java.lang.Integer,java.lang.Long> brokerEpochs,
java.util.function.Function<java.lang.Integer,java.util.concurrent.atomic.AtomicReference<java.lang.String>> brokerRemovalStateMetricRegistrationHandler,
java.util.function.Function<java.lang.Integer,java.util.concurrent.atomic.AtomicReference<java.lang.String>> brokerAdditionStateMetricRegistrationHandler) |
public EngineInitializationContext(kafka.server.KafkaConfig kafkaConfig, java.util.Map<java.lang.Integer,java.lang.Long> brokerEpochs, java.util.function.Function<java.lang.Integer,java.util.concurrent.atomic.AtomicReference<java.lang.String>> brokerRemovalStateMetricRegistrationHandler, java.util.function.Function<java.lang.Integer,java.util.concurrent.atomic.AtomicReference<java.lang.String>> brokerAdditionStateMetricRegistrationHandler)
kafkaConfig
- - the Kafka configbrokerEpochs
- - a map consisting of broker ID and the corresponding broker's epoch at the time of initializationbrokerRemovalStateMetricRegistrationHandler
- - a function that takes in a broker ID as a parameter
and registers a metric that tracks the broker removal statebrokerAdditionStateMetricRegistrationHandler
- - a function that takes in a broker ID as a parameter
and registers a metric that tracks the broker addition state