Class OpTimeTrackKafkaConsumer

java.lang.Object

io.nosqlbench.adapter.kafka.ops.OpTimeTrackKafkaClient

io.nosqlbench.adapter.kafka.ops.OpTimeTrackKafkaConsumer

public class OpTimeTrackKafkaConsumer
extends OpTimeTrackKafkaClient

Field Summary

Fields inherited from class io.nosqlbench.adapter.kafka.ops.OpTimeTrackKafkaClient

activityStartTime, kafkaSpace, maxOpTimeInSec

Constructor Summary

Constructors

Constructor

Description

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)

Method Summary

Modifier and Type	Method	Description
void	close()
int	getManualCommitTrackingCnt()
void	incManualCommitTrackingCnt()
void	resetManualCommitTrackingCnt()

Methods inherited from class io.nosqlbench.adapter.kafka.ops.OpTimeTrackKafkaClient

process

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OpTimeTrackKafkaConsumer

public 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)

Method Details

getManualCommitTrackingCnt

public int getManualCommitTrackingCnt()

incManualCommitTrackingCnt

public void incManualCommitTrackingCnt()

resetManualCommitTrackingCnt

public void resetManualCommitTrackingCnt()

close

public void close()

Specified by:

close in class OpTimeTrackKafkaClient