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 and Description
protected ConcurrentLinkedQueue<KafkaLogTailer<M>>	KafkaLogAppender.tailers

Methods in org.nuxeo.lib.stream.log.kafka that return KafkaLogTailer

Modifier and Type	Method and Description
static <M extends Externalizable> KafkaLogTailer<M>	KafkaLogTailer.createAndAssign(String prefix, Collection<LogPartition> partitions, String group, Properties consumerProps)
static <M extends Externalizable> KafkaLogTailer<M>	KafkaLogTailer.createAndSubscribe(String prefix, Collection<String> names, String group, Properties consumerProps, RebalanceListener listener)