Package io.confluent.parallelconsumer.internal

Class ConsumerManager<K,V>

java.lang.Object
io.confluent.parallelconsumer.internal.ConsumerManager<K,V>
public class ConsumerManager<K,V> extends Object
Delegate for KafkaConsumer

  • Constructor Summary

    Constructors
    Constructor
    Description
    ConsumerManager(org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    Set<org.apache.kafka.common.TopicPartition>
    assignment()
     
    void
    close(Duration defaultTimeout)
     
    void
    commitAsync(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, org.apache.kafka.clients.consumer.OffsetCommitCallback callback)
     
    void
    commitSync(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsetsToSend)
     
    org.apache.kafka.clients.consumer.ConsumerGroupMetadata
    groupMetadata()
     
    void
    onCommitRequested()
     
    void
    pause(Set<org.apache.kafka.common.TopicPartition> assignment)
     
    Set<org.apache.kafka.common.TopicPartition>
    paused()
     
    void
    resume(Set<org.apache.kafka.common.TopicPartition> pausedTopics)
     
    void
    wakeup()
    Wakes up the consumer, but only if it's polling.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ConsumerManager

      public ConsumerManager(org.apache.kafka.clients.consumer.Consumer<K,V> consumer)

  • Method Details

    • wakeup

      public void wakeup()
      Wakes up the consumer, but only if it's polling.

      Otherwise, we can interrupt other operations like KafkaConsumer.commitSync().

    • commitSync

      public void commitSync(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsetsToSend)

    • commitAsync

      public void commitAsync(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, org.apache.kafka.clients.consumer.OffsetCommitCallback callback)

    • groupMetadata

      public org.apache.kafka.clients.consumer.ConsumerGroupMetadata groupMetadata()

    • close

      public void close(Duration defaultTimeout)

    • assignment

      public Set<org.apache.kafka.common.TopicPartition> assignment()

    • pause

      public void pause(Set<org.apache.kafka.common.TopicPartition> assignment)

    • paused

      public Set<org.apache.kafka.common.TopicPartition> paused()

    • resume

      public void resume(Set<org.apache.kafka.common.TopicPartition> pausedTopics)

    • onCommitRequested

      public void onCommitRequested()