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 Details

    • group

      protected final Name group
    • lastOffsets

      protected final Map<org.apache.kafka.common.TopicPartition,Long> lastOffsets
    • lastCommittedOffsets

      protected final Map<org.apache.kafka.common.TopicPartition,Long> lastCommittedOffsets
    • records

      protected final Queue<org.apache.kafka.clients.consumer.ConsumerRecord<String,org.apache.kafka.common.utils.Bytes>> records
    • codec

      protected final Codec<M extends Externalizable> codec
    • decodeCodec

      protected final Codec<M extends Externalizable> decodeCodec
    • resolver

      protected final NameResolver resolver
    • consumer

      protected org.apache.kafka.clients.consumer.KafkaConsumer<String,org.apache.kafka.common.utils.Bytes> consumer
    • id

      protected String id
    • topicPartitions

      protected Collection<org.apache.kafka.common.TopicPartition> topicPartitions
    • partitions

      protected Collection<LogPartition> partitions
    • closed

      protected boolean closed
    • names

      protected Collection<Name> names
    • listener

      protected RebalanceListener listener
    • isRebalanced

      protected boolean isRebalanced
    • isRevoked

      protected boolean isRevoked
    • isLost

      protected boolean isLost
    • consumerMoved

      protected boolean consumerMoved
    • CONSUMER_CLIENT_ID_SEQUENCE

      protected static final AtomicInteger CONSUMER_CLIENT_ID_SEQUENCE
    • lastPollTimestamp

      protected long lastPollTimestamp
    • lastPollSize

      protected int lastPollSize
  • Constructor Details

  • Method Details