| Package | Description |
|---|---|
| com.bluejeans.common.utils.kafka |
| Modifier and Type | Method and Description |
|---|---|
List<KafkaRecordProcessor<K,V>> |
SimpleKafkaConsumer.getRecordProcessors() |
| Modifier and Type | Method and Description |
|---|---|
void |
SimpleKafkaConsumer.consumeFromPartition(String server,
String partitionString,
KafkaRecordProcessor<K,V>... kafkaRecordProcessors) |
| Modifier and Type | Method and Description |
|---|---|
void |
SimpleKafkaConsumer.setRecordProcessors(List<KafkaRecordProcessor<K,V>> recordProcessors) |
Copyright © 2016. All rights reserved.