AbstractKafkaProcessor (migoo-kafka 1.0.0 API)

java.lang.Object
- core.xyz.migoo.testelement.AbstractTestElement
- - protocol.xyz.migoo.kafka.AbstractKafkaTestElement
  - - protocol.xyz.migoo.kafka.processor.AbstractKafkaProcessor

所有已实现的接口:

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

直接已知子类:

KafkaPostProcessor, KafkaPreProcessor
```
public abstract class AbstractKafkaProcessor
extends AbstractKafkaTestElement
implements core.xyz.migoo.testelement.TestStateListener
```
作者:

mi.xiao

另请参阅:

序列化表格

- 字段概要
  - 从类继承的字段 protocol.xyz.migoo.kafka.AbstractKafkaTestElement
    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
- 构造器概要
  
  构造器
  构造器和说明
  
  AbstractKafkaProcessor()
- 方法概要
  
  所有方法实例方法具体方法
  限定符和类型方法和说明
  
  void testEnded()
  
  void testStarted()
  - 从类继承的方法 protocol.xyz.migoo.kafka.AbstractKafkaTestElement
    buildKafkaProducer, execute
  - 从类继承的方法 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

构造器
构造器和说明
`AbstractKafkaProcessor()`

所有方法实例方法具体方法
限定符和类型	方法和说明
`void`	`testEnded()`
`void`	`testStarted()`

- 构造器详细资料
  - AbstractKafkaProcessor
```
public AbstractKafkaProcessor()
```
- 方法详细资料
  - testStarted
```
public void testStarted()
```
    指定者:
    
    testStarted 在接口中 core.xyz.migoo.testelement.TestStateListener
    
    覆盖:
    
    testStarted 在类中 AbstractKafkaTestElement
  - testEnded
```
public void testEnded()
```
    指定者:
    
    testEnded 在接口中 core.xyz.migoo.testelement.TestStateListener

类 AbstractKafkaProcessor

字段概要

从类继承的字段 protocol.xyz.migoo.kafka.AbstractKafkaTestElement

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

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

构造器概要

方法概要

从类继承的方法 protocol.xyz.migoo.kafka.AbstractKafkaTestElement

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

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

构造器详细资料

AbstractKafkaProcessor

方法详细资料

testStarted

testEnded