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(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) |
static <M extends Externalizable> |
KafkaLogAppender.open(Codec<M> codec,
KafkaNamespace ns,
String name,
Properties producerProperties,
Properties consumerProperties) |
Constructor and Description |
---|
KafkaLogTailer(Codec<M> codec,
KafkaNamespace ns,
String group,
Properties consumerProps) |
Copyright © 2019 Nuxeo. All rights reserved.