com.github.panhongan.util.mq.kafka

类 MessageConsoleWriter

java.lang.Object

com.github.panhongan.util.mq.kafka.AbstractMessageProcessor

com.github.panhongan.util.mq.kafka.MessageConsoleWriter

所有已实现的接口:

Lifecycleable

public class MessageConsoleWriter
extends AbstractMessageProcessor

构造器概要

构造器

构造器和说明
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.mq.kafka.AbstractMessageProcessor

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 在类中 AbstractMessageProcessor

processMessage

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

指定者:

processMessage 在类中 AbstractMessageProcessor

init

public boolean init()

uninit

public void uninit()