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 final ConcurrentLinkedQueue<KafkaLogTailer<M>>	KafkaLogAppender.tailers

Methods 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)