Package io.confluent.parallelconsumer.internal

Class EpochAndRecordsMap<K,V>

java.lang.Object
io.confluent.parallelconsumer.internal.EpochAndRecordsMap<K,V>
public final class EpochAndRecordsMap<K,V> extends Object
For tagging polled records with our epoch
See Also:
  • BrokerPollSystem#partitionAssignmentEpoch

  • Constructor Details

    • EpochAndRecordsMap

      public EpochAndRecordsMap(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> poll, PartitionStateManager<K,V> pm)

  • Method Details

    • partitions

      public Set<org.apache.kafka.common.TopicPartition> partitions()
      Get the partitions which have records contained in this record set.
      Returns:
      the set of partitions with data in this record set (may be empty if no data was returned)

    • records

      public EpochAndRecordsMap<K,V>.RecordsAndEpoch records(org.apache.kafka.common.TopicPartition partition)
      Get just the records for the given partition
      Parameters:
      partition - The partition to get records for

    • count

      public int count()
      The number of records for all topics

    • getRecordMap

      public Map<org.apache.kafka.common.TopicPartition,EpochAndRecordsMap<K,V>.RecordsAndEpoch> getRecordMap()

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object