Uses of Class
io.nosqlbench.adapter.kafka.KafkaSpace

Packages that use KafkaSpace

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

Uses of KafkaSpace in io.nosqlbench.adapter.kafka

Subclasses with type arguments of type KafkaSpace in io.nosqlbench.adapter.kafka

Modifier and Type	Class	Description
class	KafkaDriverAdapter
class	KafkaSpace

Classes in io.nosqlbench.adapter.kafka that implement interfaces with type arguments of type KafkaSpace

Modifier and Type	Class	Description
class	KafkaOpMapper

Methods in io.nosqlbench.adapter.kafka that return types with arguments of type KafkaSpace

Modifier and Type	Method	Description
OpMapper<KafkaOp,KafkaSpace>	KafkaDriverAdapter.getOpMapper()

Method parameters in io.nosqlbench.adapter.kafka with type arguments of type KafkaSpace

Modifier and Type	Method	Description
OpDispenser<KafkaOp>	KafkaOpMapper.apply(NBComponent adapterC, ParsedOp op, LongFunction<KafkaSpace> spaceF)

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

Subclasses with type arguments of type KafkaSpace in io.nosqlbench.adapter.kafka.dispensers

Modifier and Type	Class	Description
class	KafkaBaseOpDispenser

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

Modifier and Type	Field	Description
protected final KafkaSpace	KafkaBaseOpDispenser.kafkaSpace

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

Modifier and Type	Method	Description
KafkaSpace	KafkaBaseOpDispenser.getKafkaSpace()

Constructors in io.nosqlbench.adapter.kafka.dispensers with parameters of type KafkaSpace

Modifier	Constructor	Description
protected	KafkaBaseOpDispenser(DriverAdapter adapter, ParsedOp op, LongFunction<String> topicNameStrFunc, KafkaSpace kafkaSpace)
	MessageConsumerOpDispenser(DriverAdapter adapter, ParsedOp op, LongFunction<String> tgtNameFunc, KafkaSpace kafkaSpace)
	MessageProducerOpDispenser(DriverAdapter adapter, ParsedOp op, LongFunction<String> tgtNameFunc, KafkaSpace kafkaSpace)

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

Fields in io.nosqlbench.adapter.kafka.ops declared as KafkaSpace

Modifier and Type	Field	Description
protected final KafkaSpace	KafkaOp.kafkaSpace
protected final KafkaSpace	OpTimeTrackKafkaClient.kafkaSpace

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

Modifier	Constructor	Description
	KafkaOp(KafkaAdapterMetrics kafkaAdapterMetrics, KafkaSpace kafkaSpace, OpTimeTrackKafkaClient opTimeTrackKafkaClient, Object cycleObj)
	OpTimeTrackKafkaClient(KafkaSpace kafkaSpace)
	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)
	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)