Uses of Class
io.nosqlbench.adapter.kafka.util.KafkaAdapterMetrics
Packages that use KafkaAdapterMetrics
-
Uses of KafkaAdapterMetrics in io.nosqlbench.adapter.kafka.dispensers
Fields in io.nosqlbench.adapter.kafka.dispensers declared as KafkaAdapterMetricsModifier and TypeFieldDescriptionprotected final KafkaAdapterMetricsKafkaBaseOpDispenser.kafkaAdapterMetricsMethods in io.nosqlbench.adapter.kafka.dispensers that return KafkaAdapterMetrics -
Uses of KafkaAdapterMetrics in io.nosqlbench.adapter.kafka.ops
Constructors in io.nosqlbench.adapter.kafka.ops with parameters of type KafkaAdapterMetricsModifierConstructorDescriptionKafkaOp(KafkaAdapterMetrics kafkaAdapterMetrics, KafkaSpace kafkaSpace, OpTimeTrackKafkaClient opTimeTrackKafkaClient, Object cycleObj) OpTimeTrackKafkaConsumer(KafkaSpace kafkaSpace, boolean asyncMsgCommit, int msgPoolIntervalInMs, boolean autoCommitEnabled, int maxMsgCntPerCommit, org.apache.kafka.clients.consumer.KafkaConsumer<String, String> consumer, KafkaAdapterMetrics kafkaAdapterMetrics, EndToEndStartingTimeSource e2eStartingTimeSrc, Function<String, ReceivedMessageSequenceTracker> receivedMessageSequenceTrackerForTopic, boolean seqTracking)