Package | Description |
---|---|
org.nuxeo.lib.stream.log.kafka |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentLinkedQueue<KafkaLogTailer<M>> |
KafkaLogAppender.tailers |
Modifier and Type | Method and Description |
---|---|
static <M extends Externalizable> |
KafkaLogTailer.createAndAssign(Codec<M> codec,
KafkaNamespace ns,
Collection<LogPartition> partitions,
String group,
Properties consumerProps) |
static <M extends Externalizable> |
KafkaLogTailer.createAndSubscribe(Codec<M> codec,
KafkaNamespace ns,
Collection<String> names,
String group,
Properties consumerProps,
RebalanceListener listener) |
Copyright © 2019 Nuxeo. All rights reserved.