Uses of Class
org.nuxeo.lib.stream.log.kafka.KafkaLogTailer
-
Packages that use KafkaLogTailer Package Description org.nuxeo.lib.stream.log.kafka -
-
Uses of KafkaLogTailer in org.nuxeo.lib.stream.log.kafka
Fields in org.nuxeo.lib.stream.log.kafka with type parameters of type KafkaLogTailer Modifier and Type Field Description protected ConcurrentLinkedQueue<KafkaLogTailer<M>>KafkaLogAppender. tailersMethods in org.nuxeo.lib.stream.log.kafka that return KafkaLogTailer Modifier and Type Method Description static <M extends Externalizable>
KafkaLogTailer<M>KafkaLogTailer. createAndAssign(Codec<M> codec, NameResolver resolver, Collection<LogPartition> partitions, Name group, Properties consumerProps)static <M extends Externalizable>
KafkaLogTailer<M>KafkaLogTailer. createAndSubscribe(Codec<M> codec, NameResolver resolver, Collection<Name> names, Name group, Properties consumerProps, RebalanceListener listener)
-