Uses of Class
io.nosqlbench.adapter.kafka.util.KafkaAdapterMetrics

Packages that use KafkaAdapterMetrics

Package	Description
io.nosqlbench.adapter.kafka.dispensers
io.nosqlbench.adapter.kafka.ops

Uses of KafkaAdapterMetrics in io.nosqlbench.adapter.kafka.dispensers

Fields in io.nosqlbench.adapter.kafka.dispensers declared as KafkaAdapterMetrics

Modifier and Type	Field	Description
protected final KafkaAdapterMetrics	KafkaBaseOpDispenser.kafkaAdapterMetrics

Methods in io.nosqlbench.adapter.kafka.dispensers that return KafkaAdapterMetrics

Modifier and Type	Method	Description
KafkaAdapterMetrics	KafkaBaseOpDispenser.getKafkaAdapterMetrics()

Uses of KafkaAdapterMetrics in io.nosqlbench.adapter.kafka.ops

Constructors in io.nosqlbench.adapter.kafka.ops with parameters of type KafkaAdapterMetrics

Modifier	Constructor	Description
	KafkaOp(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)