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