org.nuxeo.ecm.platform.importer.mqueues.mqueues.kafka

Class KafkaMQAppender<M extends Externalizable>

java.lang.Object

org.nuxeo.ecm.platform.importer.mqueues.mqueues.kafka.KafkaMQAppender<M>

All Implemented Interfaces:

AutoCloseable, MQAppender<M>

public class KafkaMQAppender<M extends Externalizable>
extends Object
implements MQAppender<M>

Apache Kafka implementation of MQueue.

Since:

9.2

Method Summary

Modifier and Type	Method and Description
MQOffset	append(int partition, Externalizable message) Append a message into a partition, returns MQOffset position of the message.
void	close()
boolean	closed() Returns true if the close has been closed.
String	getTopic()
String	name() Returns the MQueue's name.
static <M extends Externalizable> KafkaMQAppender<M>	open(String topic, String name, Properties producerProperties, Properties consumerProperties)
int	size() Returns the number of partitions.
boolean	waitFor(MQOffset offset, String group, Duration timeout) Wait for consumer to process a message up to the offset.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.nuxeo.ecm.platform.importer.mqueues.mqueues.MQAppender

append

Method Detail

open

public static <M extends Externalizable> KafkaMQAppender<M> open(String topic,
                                                                 String name,
                                                                 Properties producerProperties,
                                                                 Properties consumerProperties)

name

public String name()

Description copied from interface: MQAppender

Returns the MQueue's name.

Specified by:

name in interface MQAppender<M extends Externalizable>

getTopic

public String getTopic()

size

public int size()

Description copied from interface: MQAppender

Returns the number of partitions.

Specified by:

size in interface MQAppender<M extends Externalizable>

append

public MQOffset append(int partition,
                       Externalizable message)

Description copied from interface: MQAppender

Append a message into a partition, returns MQOffset position of the message. This method is thread safe, a queue can be shared by multiple producers.

Specified by:

append in interface MQAppender<M extends Externalizable>

Parameters:

partition - index lower than MQAppender.size()

waitFor

public boolean waitFor(MQOffset offset,
                       String group,
                       Duration timeout)
                throws InterruptedException

Description copied from interface: MQAppender

Wait for consumer to process a message up to the offset. The message is processed if a consumer commit its offset (or a bigger one) in the group name space. Return true if the message has been consumed, false in case of timeout.

Specified by:

waitFor in interface MQAppender<M extends Externalizable>

Throws:

InterruptedException

closed

public boolean closed()

Description copied from interface: MQAppender

Returns true if the close has been closed.

Specified by:

closed in interface MQAppender<M extends Externalizable>

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception