public class KafkaMQManager<M extends Externalizable> extends AbstractMQManager<M>
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_REPLICATION_FACTOR_PROP |
static String |
DISABLE_SUBSCRIBE_PROP |
Constructor and Description |
---|
KafkaMQManager(String zkServers,
Properties producerProperties,
Properties consumerProperties) |
KafkaMQManager(String zkServers,
String topicPrefix,
Properties producerProperties,
Properties consumerProperties) |
Modifier and Type | Method and Description |
---|---|
protected MQTailer<M> |
acquireTailer(Collection<MQPartition> partitions,
String group) |
void |
close() |
void |
create(String name,
int size) |
MQAppender<M> |
createAppender(String name) |
protected MQTailer<M> |
doSubscribe(String group,
Collection<String> names,
MQRebalanceListener listener) |
boolean |
exists(String name)
Returns
true if a MQueue with this name exists. |
Properties |
getConsumerProperties() |
Properties |
getProducerProperties() |
protected String |
getTopicName(String name) |
protected static Properties |
normalizeConsumerProperties(Properties consumerProperties) |
protected Properties |
normalizeProducerProperties(Properties producerProperties) |
boolean |
supportSubscribe()
Returns
true if the MQueue MQManager.subscribe(java.lang.String, java.util.Collection<java.lang.String>, org.nuxeo.ecm.platform.importer.mqueues.mqueues.MQRebalanceListener) method is supported. |
createIfNotExists, createTailer, createTailer, delete, getAppender, subscribe
public static final String DISABLE_SUBSCRIBE_PROP
public static final String DEFAULT_REPLICATION_FACTOR_PROP
public KafkaMQManager(String zkServers, Properties producerProperties, Properties consumerProperties)
public KafkaMQManager(String zkServers, String topicPrefix, Properties producerProperties, Properties consumerProperties)
protected String getTopicName(String name)
public void create(String name, int size)
create
in class AbstractMQManager<M extends Externalizable>
public boolean exists(String name)
MQManager
true
if a MQueue with this name
exists.public MQAppender<M> createAppender(String name)
createAppender
in class AbstractMQManager<M extends Externalizable>
protected MQTailer<M> acquireTailer(Collection<MQPartition> partitions, String group)
acquireTailer
in class AbstractMQManager<M extends Externalizable>
public Properties getProducerProperties()
public Properties getConsumerProperties()
public void close() throws Exception
close
in interface AutoCloseable
close
in class AbstractMQManager<M extends Externalizable>
Exception
public boolean supportSubscribe()
MQManager
true
if the MQueue MQManager.subscribe(java.lang.String, java.util.Collection<java.lang.String>, org.nuxeo.ecm.platform.importer.mqueues.mqueues.MQRebalanceListener)
method is supported.supportSubscribe
in interface MQManager<M extends Externalizable>
supportSubscribe
in class AbstractMQManager<M extends Externalizable>
protected MQTailer<M> doSubscribe(String group, Collection<String> names, MQRebalanceListener listener)
doSubscribe
in class AbstractMQManager<M extends Externalizable>
protected static Properties normalizeConsumerProperties(Properties consumerProperties)
protected Properties normalizeProducerProperties(Properties producerProperties)
Copyright © 2017 Nuxeo. All rights reserved.