com.github.panhongan.util.kafka

类 MessageKafkaWriter

java.lang.Object

com.github.panhongan.util.kafka.AbstractMessageProcessor

com.github.panhongan.util.kafka.MessageKafkaWriter

所有已实现的接口:

Lifecycleable

public class MessageKafkaWriter
extends AbstractMessageProcessor
implements Lifecycleable

构造器概要

构造器

构造器和说明
MessageKafkaWriter(String zk_list, String broker_list)

方法概要

方法

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

getName, setName

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

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

构造器详细资料

MessageKafkaWriter

public MessageKafkaWriter(String zk_list,
                  String broker_list)

参数:

zk_list -

broker_list -

方法详细资料

init

public boolean init()

指定者:

init 在接口中 Lifecycleable

uninit

public void uninit()

指定者:

uninit 在接口中 Lifecycleable

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