程序包 | 说明 |
---|---|
wang.bigbird.domain.framework.data.kafka.service | |
wang.bigbird.domain.framework.data.kafka.service.impl |
限定符和类型 | 方法和说明 |
---|---|
<T> void |
KafkaConsumerService.consume(String topic,
String groupId,
Class<T> messageClass,
KafkaConsumerHandler<T> handler)
消费消息
|
限定符和类型 | 方法和说明 |
---|---|
<T> void |
KafkaConsumerServiceImpl.consume(String topic,
String groupId,
Class<T> messageClass,
KafkaConsumerHandler<T> handler)
消费
|