Class KafkaSpace

java.lang.Object

io.nosqlbench.adapters.api.activityimpl.uniform.BaseSpace<KafkaSpace>

io.nosqlbench.adapter.kafka.KafkaSpace

All Implemented Interfaces:

Space, NBNamedElement, AutoCloseable

public class KafkaSpace
extends BaseSpace<KafkaSpace>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	KafkaSpace.ConsumerCacheKey
static final record	KafkaSpace.ProducerCacheKey

Nested classes/interfaces inherited from class io.nosqlbench.adapters.api.activityimpl.uniform.BaseSpace

BaseSpace.BasicSpace

Constructor Summary

Constructors

Constructor	Description
KafkaSpace(KafkaDriverAdapter adapter, int idx, NBConfiguration cfg)

Method Summary

Modifier and Type	Method	Description
void	close()
long	getActivityStartTimeMills()
String	getBootstrapSvr()
static NBConfigModel	getConfigModel()
int	getConsumerGrpNum()
KafkaClientConf	getKafkaClientConf()
int	getKafkaClntNum()
long	getMaxOpTimeInSec()
OpTimeTrackKafkaConsumer	getOpTimeTrackKafkaConsumer(KafkaSpace.ConsumerCacheKey key, Supplier<OpTimeTrackKafkaConsumer> consumerSupplier)
OpTimeTrackKafkaProducer	getOpTimeTrackKafkaProducer(KafkaSpace.ProducerCacheKey key, Supplier<OpTimeTrackKafkaProducer> producerSupplier)
long	getTotalCycleNum()
boolean	isShuttingDown()
boolean	isStrictMsgErrorHandling()
void	setTotalCycleNum(long cycleNum)
void	shutdownSpace()

Methods inherited from class io.nosqlbench.adapters.api.activityimpl.uniform.BaseSpace

getName

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaSpace

public KafkaSpace(KafkaDriverAdapter adapter,
 int idx,
 NBConfiguration cfg)

Method Details

close

public void close()

getConfigModel

public static NBConfigModel getConfigModel()

getOpTimeTrackKafkaProducer

public OpTimeTrackKafkaProducer getOpTimeTrackKafkaProducer(KafkaSpace.ProducerCacheKey key,
 Supplier<OpTimeTrackKafkaProducer> producerSupplier)

getOpTimeTrackKafkaConsumer

public OpTimeTrackKafkaConsumer getOpTimeTrackKafkaConsumer(KafkaSpace.ConsumerCacheKey key,
 Supplier<OpTimeTrackKafkaConsumer> consumerSupplier)

getActivityStartTimeMills

public long getActivityStartTimeMills()

getMaxOpTimeInSec

public long getMaxOpTimeInSec()

getBootstrapSvr

public String getBootstrapSvr()

getKafkaClientConf

public KafkaClientConf getKafkaClientConf()

getKafkaClntNum

public int getKafkaClntNum()

getConsumerGrpNum

public int getConsumerGrpNum()

isStrictMsgErrorHandling

public boolean isStrictMsgErrorHandling()

getTotalCycleNum

public long getTotalCycleNum()

setTotalCycleNum

public void setTotalCycleNum(long cycleNum)

isShuttingDown

public boolean isShuttingDown()

shutdownSpace

public void shutdownSpace()