程序包 xin.manong.stream.boost.receiver.kafka

类 KafkaProcessor

java.lang.Object

xin.manong.stream.boost.receiver.kafka.KafkaProcessor

所有已实现的接口:

xin.manong.weapon.base.kafka.KafkaRecordProcessor

public class KafkaProcessor
extends Object
implements xin.manong.weapon.base.kafka.KafkaRecordProcessor

kafka消息处理器

作者:

frankcl

构造器概要

构造器

构造器	说明
KafkaProcessor(xin.manong.stream.sdk.receiver.ReceiveProcessor receiveProcessor)

方法概要

修饰符和类型	方法	说明
void	process(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> consumerRecord)

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

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

构造器详细资料

KafkaProcessor

public KafkaProcessor(xin.manong.stream.sdk.receiver.ReceiveProcessor receiveProcessor)

方法详细资料

process

public void process(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> consumerRecord)
             throws Exception

指定者:

process 在接口中 xin.manong.weapon.base.kafka.KafkaRecordProcessor

抛出:

Exception