Package io.confluent.parallelconsumer

Class PollContextInternal<K,V>

java.lang.Object
io.confluent.parallelconsumer.PollContextInternal<K,V>
public class PollContextInternal<K,V> extends Object
Internal only view on the PollContext.

  • Constructor Details

  • Method Details

    • streamWorkContainers

      public Stream<WorkContainer<K,V>> streamWorkContainers()
      Returns:
      a stream of WorkContainers

    • getWorkContainers

      public List<WorkContainer<K,V>> getWorkContainers()
      Returns:
      a flat List of WorkContainers, which wrap the ConsumerRecords in this result set

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • getPollContext

      public PollContext<K,V> getPollContext()

    • streamInternal

      public Stream<RecordContextInternal<K,V>> streamInternal()

    • stream

      public Stream<RecordContext<K,V>> stream()

    • streamConsumerRecords

      public Stream<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> streamConsumerRecords()

    • getSingleRecord

      public RecordContext<K,V> getSingleRecord()

    • getSingleConsumerRecord

      public org.apache.kafka.clients.consumer.ConsumerRecord<K,V> getSingleConsumerRecord()

    • value

      public V value()

    • key

      public K key()

    • offset

      public long offset()

    • getContextsFlattened

      public List<RecordContext<K,V>> getContextsFlattened()

    • getConsumerRecordsFlattened

      public List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> getConsumerRecordsFlattened()

    • iterator

      public Iterator<RecordContext<K,V>> iterator()

    • forEach

      public void forEach(Consumer<? super RecordContext<K,V>> action)

    • spliterator

      public Spliterator<RecordContext<K,V>> spliterator()

    • getByTopicPartitionMap

      public Map<org.apache.kafka.common.TopicPartition,Set<RecordContext<K,V>>> getByTopicPartitionMap()

    • size

      public long size()

    • getOffsetsFlattened

      public List<Long> getOffsetsFlattened()

    • getOffsets

      public Map<org.apache.kafka.common.TopicPartition,List<Long>> getOffsets()