Uses of Interface
org.nuxeo.lib.stream.log.RebalanceListener

Packages that use RebalanceListener

Package	Description
org.nuxeo.importer.stream.automation
org.nuxeo.lib.stream.computation.log	Computation pattern implemented with Log
org.nuxeo.lib.stream.log	The Log interface with Chronicle and Kafka implementation.
org.nuxeo.lib.stream.log.chronicle
org.nuxeo.lib.stream.log.internals
org.nuxeo.lib.stream.log.kafka
org.nuxeo.lib.stream.pattern.consumer.internals

Uses of RebalanceListener in org.nuxeo.importer.stream.automation

Classes in org.nuxeo.importer.stream.automation that implement RebalanceListener

Modifier and Type	Class and Description
class	RandomDocumentProducers

Uses of RebalanceListener in org.nuxeo.lib.stream.computation.log

Classes in org.nuxeo.lib.stream.computation.log that implement RebalanceListener

Modifier and Type	Class and Description
class	ComputationRunner Thread driving a Computation

Uses of RebalanceListener in org.nuxeo.lib.stream.log

Methods in org.nuxeo.lib.stream.log with parameters of type RebalanceListener

Modifier and Type	Method and Description
<M extends Externalizable> LogTailer<M>	LogManager.subscribe(String group, Collection<String> names, RebalanceListener listener) Create a tailer for a consumer group and subscribe to multiple Logs.

Uses of RebalanceListener in org.nuxeo.lib.stream.log.chronicle

Methods in org.nuxeo.lib.stream.log.chronicle with parameters of type RebalanceListener

Modifier and Type	Method and Description
protected <M extends Externalizable> LogTailer<M>	ChronicleLogManager.doSubscribe(String group, Collection<String> names, RebalanceListener listener)

Uses of RebalanceListener in org.nuxeo.lib.stream.log.internals

Methods in org.nuxeo.lib.stream.log.internals with parameters of type RebalanceListener

Modifier and Type	Method and Description
protected abstract <M extends Externalizable> LogTailer<M>	AbstractLogManager.doSubscribe(String group, Collection<String> names, RebalanceListener listener)
<M extends Externalizable> LogTailer<M>	AbstractLogManager.subscribe(String group, Collection<String> names, RebalanceListener listener)

Uses of RebalanceListener in org.nuxeo.lib.stream.log.kafka

Fields in org.nuxeo.lib.stream.log.kafka declared as RebalanceListener

Modifier and Type	Field and Description
protected RebalanceListener	KafkaLogTailer.listener

Methods in org.nuxeo.lib.stream.log.kafka with parameters of type RebalanceListener

Modifier and Type	Method and Description
static <M extends Externalizable> KafkaLogTailer<M>	KafkaLogTailer.createAndSubscribe(String prefix, Collection<String> names, String group, Properties consumerProps, RebalanceListener listener)
protected <M extends Externalizable> LogTailer<M>	KafkaLogManager.doSubscribe(String group, Collection<String> names, RebalanceListener listener)

Uses of RebalanceListener in org.nuxeo.lib.stream.pattern.consumer.internals

Classes in org.nuxeo.lib.stream.pattern.consumer.internals that implement RebalanceListener

Modifier and Type	Class and Description
class	ConsumerRunner<M extends Message> Read messages from a tailer and drive a consumer according to its policy.