com.github.panhongan.util.kafka

类 MessageKafkaWriter

java.lang.Object

com.github.panhongan.util.kafka.AbstractKafkaMessageHandler

com.github.panhongan.util.kafka.MessageKafkaWriter

所有已实现的接口:

Lifecycleable

public class MessageKafkaWriter
extends AbstractKafkaMessageHandler
implements Lifecycleable

构造器概要

构造器

构造器和说明
MessageKafkaWriter(Config producer_config, String send_failed_data_dir)
MessageKafkaWriter(Config producer_config, String dst_topic, String send_failed_data_dir)

方法概要

方法

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

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

getName, setName

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

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

构造器详细资料

MessageKafkaWriter

public MessageKafkaWriter(Config producer_config,
                  String send_failed_data_dir)

参数:

producer_config - : producer config

send_failed_data_dir - : if send failed, records will saved here

MessageKafkaWriter

public MessageKafkaWriter(Config producer_config,
                  String dst_topic,
                  String send_failed_data_dir)

参数:

producer_config - : producer config

dst_topic - : send topic

send_failed_data_dir - : if send failed, records will saved here

方法详细资料

setSendTopic

public void setSendTopic(String send_topic)

init

public boolean init()

指定者:

init 在接口中 Lifecycleable

uninit

public void uninit()

指定者:

uninit 在接口中 Lifecycleable

processMessage

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

指定者:

processMessage 在类中 AbstractKafkaMessageHandler

参数:

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

参数:

topic - : data source topic

partition_id - : data source topic partition

msg_list - : message set

返回:

Object