Class Hierarchy
- java.lang.Object
- org.nuxeo.ecm.platform.importer.mqueues.mqueues.internals.AbstractMQManager<M> (implements org.nuxeo.ecm.platform.importer.mqueues.mqueues.MQManager<M>)
- org.nuxeo.ecm.platform.importer.mqueues.mqueues.kafka.KafkaMQManager<M>
- org.nuxeo.ecm.platform.importer.mqueues.mqueues.kafka.KafkaMQAppender<M> (implements org.nuxeo.ecm.platform.importer.mqueues.mqueues.MQAppender<M>)
- org.nuxeo.ecm.platform.importer.mqueues.mqueues.kafka.KafkaMQTailer<M> (implements org.apache.kafka.clients.consumer.ConsumerRebalanceListener, org.nuxeo.ecm.platform.importer.mqueues.mqueues.MQTailer<M>)
- org.nuxeo.ecm.platform.importer.mqueues.mqueues.kafka.KafkaUtils (implements java.lang.AutoCloseable)
Copyright © 2017 Nuxeo. All rights reserved.