com.github.panhongan.util.kafka

类 AbstractKafkaMessageProcessor

java.lang.Object

com.github.panhongan.util.kafka.AbstractKafkaMessageProcessor

所有已实现的接口:

Lifecycleable

直接已知子类:

KafkaMessageWorkflow, MessageConsoleWriter, MessageKafkaWriter, MessageLocalWriter

public abstract class AbstractKafkaMessageProcessor
extends Object
implements Lifecycleable

构造器概要

构造器

构造器和说明
AbstractKafkaMessageProcessor()
AbstractKafkaMessageProcessor(String name)

方法概要

限定符和类型	方法和说明
String	getName()
abstract Object	processMessage(String topic, int partition_id, List<String> message)
abstract Object	processMessage(String topic, int partition_id, String message)
void	setName(String name)

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

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

从接口继承的方法 com.github.panhongan.util.control.Lifecycleable

init, uninit

构造器详细资料

AbstractKafkaMessageProcessor

public AbstractKafkaMessageProcessor()

AbstractKafkaMessageProcessor

public AbstractKafkaMessageProcessor(String name)

方法详细资料

setName

public void setName(String name)

getName

public String getName()

processMessage

public abstract Object processMessage(String topic,
                                      int partition_id,
                                      String message)

参数:

topic - : data source topic

partition_id - : data source topic partition

message - : message

返回:

Object

processMessage

public abstract Object processMessage(String topic,
                                      int partition_id,
                                      List<String> message)

参数:

topic - : data source topic

partition_id - : data source topic partition

message - : message set

返回:

Object