| 限定符和类型 | 类和说明 |
|---|---|
class |
KafkaBatchContextImpl
批量消费上下文的默认实现
|
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
KafkaBatchListener.asyncConsume(List<List<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>>> pageList,
KafkaBatchContext context)
多线程消费
|
boolean |
KafkaBatchListener.asyncConsume(List<List<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>>> pageList,
KafkaBatchContext context)
多线程消费
|
boolean |
KafkaBatchConsumer.consume(List<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>> records,
KafkaBatchContext context)
执行消费
|
boolean |
KafkaBatchListener.consume(List<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>> records,
KafkaBatchContext context)
执行消费
|
boolean |
KafkaBatchListener.consume(List<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>> records,
KafkaBatchContext context)
执行消费
|
boolean |
KafkaBatchConsumer.consume(List<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>> records,
KafkaBatchContext context)
执行消费
|
boolean |
KafkaBatchListener.listen(List<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>> records,
KafkaBatchContext context)
计算分页,多线程消费
|
boolean |
KafkaBatchListener.listen(List<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>> records,
KafkaBatchContext context)
计算分页,多线程消费
|
Copyright © 2023. All rights reserved.