Uses of Interface
org.nuxeo.lib.stream.log.RebalanceListener
-
Packages that use RebalanceListener Package Description org.nuxeo.lib.stream.computation.log Computation pattern implemented with Logorg.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.lib.stream.computation.log
Classes in org.nuxeo.lib.stream.computation.log that implement RebalanceListener Modifier and Type Class Description class
ComputationRunner
Thread driving a ComputationMethods in org.nuxeo.lib.stream.computation.log with parameters of type RebalanceListener Modifier and Type Method Description LogTailer<Record>
LogStreamManager. subscribe(Name computationName, Collection<Name> streams, RebalanceListener listener)
-
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 Description default <M extends Externalizable>
LogTailer<M>LogManager. subscribe(String group, Collection<String> names, RebalanceListener listener)
Deprecated.since 11.1 useLogManager.subscribe(Name, Collection, RebalanceListener)
insteaddefault <M extends Externalizable>
LogTailer<M>LogManager. subscribe(String group, Collection<String> names, RebalanceListener listener, Codec<M> codec)
Deprecated.since 11.1 useLogManager.subscribe(Name, Collection, RebalanceListener, Codec)
insteaddefault <M extends Externalizable>
LogTailer<M>LogManager. subscribe(Name group, Collection<Name> names, RebalanceListener listener)
<M extends Externalizable>
LogTailer<M>LogManager. subscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)
Creates a tailer for a consumergroup
and subscribe to multiple Logs.<M extends Externalizable>
LogTailer<M>UnifiedLogManager. subscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)
-
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 Description protected <M extends Externalizable>
LogTailer<M>ChronicleLogManager. doSubscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)
-
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 Description protected abstract <M extends Externalizable>
LogTailer<M>AbstractLogManager. doSubscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)
<M extends Externalizable>
LogTailer<M>AbstractLogManager. subscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)
-
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 Description protected RebalanceListener
KafkaLogTailer. listener
Methods in org.nuxeo.lib.stream.log.kafka with parameters of type RebalanceListener Modifier and Type Method Description static <M extends Externalizable>
KafkaLogTailer<M>KafkaLogTailer. createAndSubscribe(Codec<M> codec, NameResolver resolver, Collection<Name> names, Name group, Properties consumerProps, RebalanceListener listener)
protected <M extends Externalizable>
LogTailer<M>KafkaLogManager. doSubscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)
-
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 Description class
ConsumerRunner<M extends Message>
Read messages from a tailer and drive a consumer according to its policy.
-