com.github.panhongan.util.kafka

类 MessageConsoleWriter

java.lang.Object

com.github.panhongan.util.kafka.AbstractKafkaMessageProcessor

com.github.panhongan.util.kafka.MessageConsoleWriter

所有已实现的接口:

Lifecycleable

public class MessageConsoleWriter
extends AbstractKafkaMessageProcessor

构造器概要

构造器

构造器和说明
MessageConsoleWriter()

方法概要

限定符和类型	方法和说明
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

构造器详细资料

MessageConsoleWriter

public MessageConsoleWriter()

方法详细资料

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

init

public boolean init()

uninit

public void uninit()