Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.computation.mqueue |
Computation pattern with an implementation using MQueue.
|
org.nuxeo.ecm.platform.importer.mqueues.mqueues |
The MQueue interface with Chronicle and Kafka implementation.
|
org.nuxeo.ecm.platform.importer.mqueues.mqueues.chronicle | |
org.nuxeo.ecm.platform.importer.mqueues.mqueues.internals | |
org.nuxeo.ecm.platform.importer.mqueues.mqueues.kafka | |
org.nuxeo.ecm.platform.importer.mqueues.pattern.consumer.internals |
Modifier and Type | Method and Description |
---|---|
void |
MQComputationRunner.onPartitionsAssigned(Collection<MQPartition> partitions) |
void |
MQComputationRunner.onPartitionsRevoked(Collection<MQPartition> partitions) |
Constructor and Description |
---|
MQComputationPool(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<List<MQPartition>> defaultAssignments,
MQManager<Record> manager) |
MQComputationRunner(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<MQPartition> defaultAssignment,
MQManager<Record> mqManager) |
Modifier and Type | Field and Description |
---|---|
protected MQPartition |
MQRecord.partition |
Modifier and Type | Method and Description |
---|---|
static MQPartition |
MQPartition.of(String name,
int partition) |
MQPartition |
MQRecord.partition()
Returns the partition where the message has been read.
|
MQPartition |
MQOffset.partition()
Returns the tuple MQueue and partition.
|
Modifier and Type | Method and Description |
---|---|
Collection<MQPartition> |
MQTailer.assignments()
Returns the list of MQueue name/partition tuples currently assigned to this tailer.
|
Modifier and Type | Method and Description |
---|---|
MQOffset |
MQTailer.commit(MQPartition partition)
Commit current position for the partition.
|
MQTailer<M> |
MQManager.createTailer(String group,
MQPartition partition)
Create a tailer for a consumer
group and assign a single partition . |
Modifier and Type | Method and Description |
---|---|
MQTailer<M> |
MQManager.createTailer(String group,
Collection<MQPartition> partitions)
Create a tailer for a consumer
group and assign multiple partitions . |
void |
MQRebalanceListener.onPartitionsAssigned(Collection<MQPartition> partitions) |
void |
MQRebalanceListener.onPartitionsRevoked(Collection<MQPartition> partitions) |
Constructor and Description |
---|
MQRecord(MQPartition partition,
M message,
MQOffset offset) |
Modifier and Type | Method and Description |
---|---|
Collection<MQPartition> |
ChronicleMQTailer.assignments() |
Collection<MQPartition> |
ChronicleCompoundMQTailer.assignments() |
Modifier and Type | Method and Description |
---|---|
MQOffset |
ChronicleMQTailer.commit(MQPartition partition) |
MQOffset |
ChronicleCompoundMQTailer.commit(MQPartition partition) |
MQTailer<M> |
ChronicleMQAppender.createTailer(MQPartition partition,
String group) |
void |
ChronicleMQTailer.seek(MQPartition partition,
MQOffset offset) |
void |
ChronicleCompoundMQTailer.seek(MQPartition partition,
MQOffset offset) |
Modifier and Type | Method and Description |
---|---|
protected MQTailer<M> |
ChronicleMQManager.acquireTailer(Collection<MQPartition> partitions,
String group) |
Constructor and Description |
---|
ChronicleMQTailer(String basePath,
net.openhft.chronicle.queue.ExcerptTailer cqTailer,
MQPartition partition,
String group) |
Modifier and Type | Field and Description |
---|---|
protected MQPartition |
MQOffsetImpl.partition |
Modifier and Type | Method and Description |
---|---|
MQPartition |
MQOffsetImpl.partition() |
Modifier and Type | Method and Description |
---|---|
MQTailer<M> |
AbstractMQManager.createTailer(String group,
MQPartition partition) |
Modifier and Type | Method and Description |
---|---|
protected abstract MQTailer<M> |
AbstractMQManager.acquireTailer(Collection<MQPartition> partitions,
String group) |
MQTailer<M> |
AbstractMQManager.createTailer(String group,
Collection<MQPartition> partitions) |
Constructor and Description |
---|
MQOffsetImpl(MQPartition partition,
long offset) |
MQPartitionGroup(String group,
MQPartition mqp) |
Modifier and Type | Method and Description |
---|---|
Collection<MQPartition> |
KafkaMQTailer.assignments() |
protected static List<List<MQPartition>> |
KafkaUtils.assignments(org.apache.kafka.clients.consumer.internals.PartitionAssignor assignor,
int threads,
Map<String,Integer> streams) |
static List<List<MQPartition>> |
KafkaUtils.rangeAssignments(int threads,
Map<String,Integer> streams) |
static List<List<MQPartition>> |
KafkaUtils.roundRobinAssignments(int threads,
Map<String,Integer> streams) |
Modifier and Type | Method and Description |
---|---|
MQOffset |
KafkaMQTailer.commit(MQPartition partition) |
void |
KafkaMQTailer.seek(MQPartition partition,
MQOffset offset) |
Modifier and Type | Method and Description |
---|---|
protected MQTailer<M> |
KafkaMQManager.acquireTailer(Collection<MQPartition> partitions,
String group) |
static <M extends Externalizable> |
KafkaMQTailer.createAndAssign(String prefix,
Collection<MQPartition> partitions,
String group,
Properties consumerProps) |
Modifier and Type | Method and Description |
---|---|
void |
ConsumerRunner.onPartitionsAssigned(Collection<MQPartition> partitions) |
void |
ConsumerRunner.onPartitionsRevoked(Collection<MQPartition> partitions) |
Constructor and Description |
---|
ConsumerRunner(ConsumerFactory<M> factory,
ConsumerPolicy policy,
MQManager<M> manager,
List<MQPartition> defaultAssignments) |
Copyright © 2017 Nuxeo. All rights reserved.