Package org.nuxeo.lib.stream.log.kafka
Class KafkaLogTailer<M extends Externalizable>
java.lang.Object
org.nuxeo.lib.stream.log.kafka.KafkaLogTailer<M>
- All Implemented Interfaces:
AutoCloseable
,org.apache.kafka.clients.consumer.ConsumerRebalanceListener
,LogTailer<M>
public class KafkaLogTailer<M extends Externalizable>
extends Object
implements LogTailer<M>, org.apache.kafka.clients.consumer.ConsumerRebalanceListener
- Since:
- 9.3
-
Field Summary
Modifier and TypeFieldDescriptionprotected boolean
protected org.apache.kafka.clients.consumer.KafkaConsumer<String,
org.apache.kafka.common.utils.Bytes> protected static final AtomicInteger
protected boolean
protected final Name
protected String
protected boolean
protected boolean
protected boolean
protected int
protected long
protected RebalanceListener
protected Collection<Name>
protected Collection<LogPartition>
protected final Queue<org.apache.kafka.clients.consumer.ConsumerRecord<String,
org.apache.kafka.common.utils.Bytes>> protected final NameResolver
protected Collection<org.apache.kafka.common.TopicPartition>
-
Constructor Summary
ModifierConstructorDescriptionprotected
KafkaLogTailer
(Codec<M> codec, NameResolver resolver, Name group, Properties consumerProps) -
Method Summary
Modifier and TypeMethodDescriptionReturns the list of Log name, partitions tuples currently assigned to this tailer.protected static String
buildId
(Name group, Collection<LogPartition> partitions) protected static String
buildSubscribeId
(Name group, Collection<Name> names) protected void
void
close()
boolean
closed()
Returnstrue
if the tailer has been closed.void
commit()
Commit current positions for all partitions (last message offset returned by read).commit
(LogPartition partition) Commit current position for the partition.static <M extends Externalizable>
KafkaLogTailer<M>createAndAssign
(Codec<M> codec, NameResolver resolver, Collection<LogPartition> partitions, Name group, Properties consumerProps) static <M extends Externalizable>
KafkaLogTailer<M>createAndSubscribe
(Codec<M> codec, NameResolver resolver, Collection<Name> names, Name group, Properties consumerProps, RebalanceListener listener) protected void
Commits the consumer at its current position regardless of lastOffsets or lastCommittedOffsetsgetCodec()
Returns the codec used to read the records.group()
Returns the consumer group.offsetForTimestamp
(LogPartition partition, long timestamp) Look up the offset for the given partition by timestamp.void
onPartitionsAssigned
(Collection<org.apache.kafka.common.TopicPartition> newPartitions) void
onPartitionsLost
(Collection<org.apache.kafka.common.TopicPartition> partitions) void
onPartitionsRevoked
(Collection<org.apache.kafka.common.TopicPartition> partitions) protected int
Read a message from assigned partitions within the timeout.void
reset()
Reset all committed positions for this group, next read will be done from beginning.void
reset
(LogPartition partition) Reset the committed position for this group on this partition, next read for this partition will be done from the beginning.void
Set the current position for a single partition.void
toEnd()
Set the current positions to the end of all partitions.void
Set the current positions to previously committed positions.protected long
toLastCommitted
(org.apache.kafka.common.TopicPartition topicPartition) void
toStart()
Set the current positions to the beginning of all partitions.toString()
-
Field Details
-
group
-
lastOffsets
-
lastCommittedOffsets
-
records
-
codec
-
decodeCodec
-
resolver
-
consumer
protected org.apache.kafka.clients.consumer.KafkaConsumer<String,org.apache.kafka.common.utils.Bytes> consumer -
id
-
topicPartitions
-
partitions
-
closed
protected boolean closed -
names
-
listener
-
isRebalanced
protected boolean isRebalanced -
isRevoked
protected boolean isRevoked -
isLost
protected boolean isLost -
consumerMoved
protected boolean consumerMoved -
CONSUMER_CLIENT_ID_SEQUENCE
-
lastPollTimestamp
protected long lastPollTimestamp -
lastPollSize
protected int lastPollSize
-
-
Constructor Details
-
KafkaLogTailer
protected KafkaLogTailer(Codec<M> codec, NameResolver resolver, Name group, Properties consumerProps)
-
-
Method Details
-
createAndAssign
public static <M extends Externalizable> KafkaLogTailer<M> createAndAssign(Codec<M> codec, NameResolver resolver, Collection<LogPartition> partitions, Name group, Properties consumerProps) -
createAndSubscribe
public static <M extends Externalizable> KafkaLogTailer<M> createAndSubscribe(Codec<M> codec, NameResolver resolver, Collection<Name> names, Name group, Properties consumerProps, RebalanceListener listener) -
buildId
-
buildSubscribeId
-
read
Description copied from interface:LogTailer
Read a message from assigned partitions within the timeout.- Specified by:
read
in interfaceLogTailer<M extends Externalizable>
- Returns:
- null if there is no message in the queue after the timeout.
- Throws:
InterruptedException
-
poll
- Throws:
InterruptedException
-
toEnd
public void toEnd()Description copied from interface:LogTailer
Set the current positions to the end of all partitions.- Specified by:
toEnd
in interfaceLogTailer<M extends Externalizable>
-
toStart
public void toStart()Description copied from interface:LogTailer
Set the current positions to the beginning of all partitions.- Specified by:
toStart
in interfaceLogTailer<M extends Externalizable>
-
toLastCommitted
public void toLastCommitted()Description copied from interface:LogTailer
Set the current positions to previously committed positions.- Specified by:
toLastCommitted
in interfaceLogTailer<M extends Externalizable>
-
toLastCommitted
protected long toLastCommitted(org.apache.kafka.common.TopicPartition topicPartition) -
seek
Description copied from interface:LogTailer
Set the current position for a single partition. Do not change other partitions positions.- Specified by:
seek
in interfaceLogTailer<M extends Externalizable>
-
reset
public void reset()Description copied from interface:LogTailer
Reset all committed positions for this group, next read will be done from beginning.- Specified by:
reset
in interfaceLogTailer<M extends Externalizable>
-
reset
Description copied from interface:LogTailer
Reset the committed position for this group on this partition, next read for this partition will be done from the beginning.- Specified by:
reset
in interfaceLogTailer<M extends Externalizable>
-
offsetForTimestamp
Description copied from interface:LogTailer
Look up the offset for the given partition by timestamp. The position is the earliest offset whose timestamp is greater than or equal to the given timestamp.The timestamp used depends on the implementation, for Kafka this is the LogAppendTime. Returns null if no record offset is found with an appropriate timestamp.
- Specified by:
offsetForTimestamp
in interfaceLogTailer<M extends Externalizable>
-
commit
public void commit()Description copied from interface:LogTailer
Commit current positions for all partitions (last message offset returned by read).- Specified by:
commit
in interfaceLogTailer<M extends Externalizable>
-
forceCommit
protected void forceCommit()Commits the consumer at its current position regardless of lastOffsets or lastCommittedOffsets -
commit
Description copied from interface:LogTailer
Commit current position for the partition.- Specified by:
commit
in interfaceLogTailer<M extends Externalizable>
- Returns:
- the committed offset, can return null if there was no previous read done on this partition.
-
assignments
Description copied from interface:LogTailer
Returns the list of Log name, partitions tuples currently assigned to this tailer. Assignments can change only if the tailer has been created usingLogManager.subscribe(org.nuxeo.lib.stream.log.Name, java.util.Collection<org.nuxeo.lib.stream.log.Name>, org.nuxeo.lib.stream.log.RebalanceListener, org.nuxeo.lib.stream.codec.Codec<M>)
.- Specified by:
assignments
in interfaceLogTailer<M extends Externalizable>
-
group
Description copied from interface:LogTailer
Returns the consumer group.- Specified by:
group
in interfaceLogTailer<M extends Externalizable>
-
closed
public boolean closed()Description copied from interface:LogTailer
Returnstrue
if the tailer has been closed.- Specified by:
closed
in interfaceLogTailer<M extends Externalizable>
-
getCodec
Description copied from interface:LogTailer
Returns the codec used to read the records. A null codec is the default legacy encoding.- Specified by:
getCodec
in interfaceLogTailer<M extends Externalizable>
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceLogTailer<M extends Externalizable>
-
toString
-
onPartitionsRevoked
- Specified by:
onPartitionsRevoked
in interfaceorg.apache.kafka.clients.consumer.ConsumerRebalanceListener
-
onPartitionsAssigned
- Specified by:
onPartitionsAssigned
in interfaceorg.apache.kafka.clients.consumer.ConsumerRebalanceListener
-
onPartitionsLost
- Specified by:
onPartitionsLost
in interfaceorg.apache.kafka.clients.consumer.ConsumerRebalanceListener
-
cleanDuringRebalancing
protected void cleanDuringRebalancing()
-