Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.mqueues.kafka |
Modifier and Type | Method and Description |
---|---|
static <M extends Externalizable> |
KafkaMQTailer.createAndAssign(String prefix,
Collection<MQPartition> partitions,
String group,
Properties consumerProps) |
static <M extends Externalizable> |
KafkaMQTailer.createAndSubscribe(String prefix,
Collection<String> names,
String group,
Properties consumerProps,
MQRebalanceListener listener) |
Copyright © 2017 Nuxeo. All rights reserved.