protocol.xyz.migoo.kafka

类 AbstractKafkaTestElement

java.lang.Object

core.xyz.migoo.testelement.AbstractTestElement

protocol.xyz.migoo.kafka.AbstractKafkaTestElement

所有已实现的接口:

core.xyz.migoo.testelement.TestElement, core.xyz.migoo.variables.VariableStateListener, Serializable, KafkaConstantsInterface

直接已知子类:

AbstractKafkaProcessor, KafkaDefaults, KafkaSampler

public abstract class AbstractKafkaTestElement
extends core.xyz.migoo.testelement.AbstractTestElement
implements KafkaConstantsInterface

作者:

xiaomi Created in 2021/11/11 11:08

另请参阅:

序列化表格

字段概要

字段

限定符和类型	字段和说明
protected org.apache.kafka.clients.producer.KafkaProducer<String,String>	producer

从类继承的字段 core.xyz.migoo.testelement.AbstractTestElement

CHILDS, CONFIG_ELEMENTS, EXTRACTORS, POSTPROCESSORS, PREPROCESSORS, REPORT_ELEMENT, SLEEP, TEST_CLASS, TEST_ELEMENTS, TITLE, VALIDATORS, VARIABLES

从接口继承的字段 protocol.xyz.migoo.kafka.util.KafkaConstantsInterface

ACKS_CONFIG, BOOTSTRAP_SERVERS_CONFIG, KAFKA_DEFAULT, KAFKA_KEY, KAFKA_MESSAGE, KAFKA_PRODUCER, KAFKA_TOPIC, KEY_SERIALIZER_CLASS_CONFIG, LINGER_MS_CONFIG, RETRIES_CONFIG, VALUE_SERIALIZER_CLASS_CONFIG

构造器概要

构造器

构造器和说明
AbstractKafkaTestElement()

方法概要

限定符和类型	方法和说明
protected org.apache.kafka.clients.producer.KafkaProducer<String,String>	buildKafkaProducer()
protected core.xyz.migoo.samplers.SampleResult	execute(KafkaSampleResult result)
void	testStarted()

从类继承的方法 core.xyz.migoo.testelement.AbstractTestElement

addChildTestElement, convertVariable, get, get, getChildTestElements, getProperty, getPropertyAsBoolean, getPropertyAsDouble, getPropertyAsFloat, getPropertyAsInt, getPropertyAsJSONArray, getPropertyAsJSONObject, getPropertyAsLong, getPropertyAsMiGooProperty, getPropertyAsString, getVariables, removeProperty, setProperties, setProperty, setVariables

从类继承的方法 java.lang.Object

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

字段详细资料

producer

protected org.apache.kafka.clients.producer.KafkaProducer<String,String> producer

构造器详细资料

AbstractKafkaTestElement

public AbstractKafkaTestElement()

方法详细资料

buildKafkaProducer

protected org.apache.kafka.clients.producer.KafkaProducer<String,String> buildKafkaProducer()

testStarted

public void testStarted()

execute

protected core.xyz.migoo.samplers.SampleResult execute(KafkaSampleResult result)
                                                throws Exception

抛出:

Exception