Class OpTimeTrackKafkaProducer

java.lang.Object

io.nosqlbench.adapter.kafka.ops.OpTimeTrackKafkaClient

io.nosqlbench.adapter.kafka.ops.OpTimeTrackKafkaProducer

public class OpTimeTrackKafkaProducer
extends OpTimeTrackKafkaClient

Field Summary

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

activityStartTime, kafkaSpace, maxOpTimeInSec

Constructor Summary

Constructors

Constructor	Description
OpTimeTrackKafkaProducer(KafkaSpace kafkaSpace, boolean asyncMsgAck, boolean transactEnabledConfig, int txnBatchNum, boolean seqTracking, Set<EndToEndMetricsAdapterUtil.MSG_SEQ_ERROR_SIMU_TYPE> errSimuTypeSet, org.apache.kafka.clients.producer.KafkaProducer<String,String> producer)

Method Summary

Modifier and Type	Method	Description
void	close()
static int	getTxnBatchTrackingCntTL()
static io.nosqlbench.adapter.kafka.ops.OpTimeTrackKafkaProducer.TxnProcResult	getTxnProcResultTL()
static void	incTxnBatchTrackingCnt()
static void	resetTxnBatchTrackingCnt()
static void	resetTxnProcResultTL(io.nosqlbench.adapter.kafka.ops.OpTimeTrackKafkaProducer.TxnProcResult result)
static void	setTxnProcResultTL(io.nosqlbench.adapter.kafka.ops.OpTimeTrackKafkaProducer.TxnProcResult result)

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

OpTimeTrackKafkaProducer

public OpTimeTrackKafkaProducer(KafkaSpace kafkaSpace,
 boolean asyncMsgAck,
 boolean transactEnabledConfig,
 int txnBatchNum,
 boolean seqTracking,
 Set<EndToEndMetricsAdapterUtil.MSG_SEQ_ERROR_SIMU_TYPE> errSimuTypeSet,
 org.apache.kafka.clients.producer.KafkaProducer<String,String> producer)

Method Details

getTxnBatchTrackingCntTL

public static int getTxnBatchTrackingCntTL()

incTxnBatchTrackingCnt

public static void incTxnBatchTrackingCnt()

resetTxnBatchTrackingCnt

public static void resetTxnBatchTrackingCnt()

getTxnProcResultTL

public static io.nosqlbench.adapter.kafka.ops.OpTimeTrackKafkaProducer.TxnProcResult getTxnProcResultTL()

setTxnProcResultTL

public static void setTxnProcResultTL(io.nosqlbench.adapter.kafka.ops.OpTimeTrackKafkaProducer.TxnProcResult result)

resetTxnProcResultTL

public static void resetTxnProcResultTL(io.nosqlbench.adapter.kafka.ops.OpTimeTrackKafkaProducer.TxnProcResult result)

close

public void close()

Specified by:

close in class OpTimeTrackKafkaClient