wang.bigbird.domain.framework.data.kafka.service.impl

类 KafkaConsumerServiceImpl

java.lang.Object

wang.bigbird.domain.framework.data.kafka.service.impl.KafkaConsumerServiceImpl

所有已实现的接口:

KafkaConsumerService

@Service
public class KafkaConsumerServiceImpl
extends Object
implements KafkaConsumerService

kafka消费者服务

作者:

Bigbird

构造器概要

构造器

构造器和说明
KafkaConsumerServiceImpl()

方法概要

限定符和类型	方法和说明
<T> void	consume(String topic, String groupId, Class<T> messageClass, KafkaConsumerHandler<T> handler) 消费
void	destroy() 注销consumer

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

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

构造器详细资料

KafkaConsumerServiceImpl

public KafkaConsumerServiceImpl()

方法详细资料

consume

public <T> void consume(String topic,
                        String groupId,
                        Class<T> messageClass,
                        KafkaConsumerHandler<T> handler)

消费

指定者:

consume 在接口中 KafkaConsumerService

参数:

topic - 主题

groupId - 消费组

messageClass - 消息类型

handler - 函数式处理

destroy

@PreDestroy
public void destroy()

注销consumer