com.github.panhongan.util.kafka.handler

类 KafkaMessageWorkflow

java.lang.Object

com.github.panhongan.util.kafka.AbstractKafkaMessageProcessor

com.github.panhongan.util.kafka.handler.KafkaMessageWorkflow

所有已实现的接口:

Lifecycleable

public class KafkaMessageWorkflow
extends AbstractKafkaMessageProcessor

嵌套类概要

嵌套类

限定符和类型	类和说明
class	KafkaMessageWorkflow.InnerMessageProcessor

构造器概要

构造器

构造器和说明
KafkaMessageWorkflow(AbstractMessageHandler handler, MessageKafkaWriter kafka_writer, KafkaMessageServiceConfig config)

方法概要

方法

限定符和类型	方法和说明
boolean	init()
Object	processMessage(String topic, int partition_id, List<String> msg_list)
Object	processMessage(String topic, int partition_id, String message)
void	uninit()

从类继承的方法 com.github.panhongan.util.kafka.AbstractKafkaMessageProcessor

getName, setName

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

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

构造器详细资料

KafkaMessageWorkflow

public KafkaMessageWorkflow(AbstractMessageHandler handler,
                    MessageKafkaWriter kafka_writer,
                    KafkaMessageServiceConfig config)

方法详细资料

init

public boolean init()

uninit

public void uninit()

processMessage

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

指定者:

processMessage 在类中 AbstractKafkaMessageProcessor

参数:

topic - : data source topic

partition_id - : data source topic partition

message - : message

返回:

Object

processMessage

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

指定者:

processMessage 在类中 AbstractKafkaMessageProcessor

参数:

topic - : data source topic

partition_id - : data source topic partition

msg_list - : message set

返回:

Object