Interface ShareConsumer<K,V>

Method Details

• subscription

  Set<String> subscription()

  See Also:

  • KafkaShareConsumer.subscription()

• subscribe

  void subscribe(Collection<String> topics)

  See Also:

  • KafkaShareConsumer.subscribe(Collection)

• unsubscribe

  void unsubscribe()

  See Also:

  • KafkaShareConsumer.unsubscribe()

• poll

  ConsumerRecords<K,V> poll(Duration timeout)

  See Also:

  • KafkaShareConsumer.poll(Duration)

• acknowledge

  void acknowledge(ConsumerRecord<K,V> record)

  See Also:

  • KafkaShareConsumer.acknowledge(ConsumerRecord)

• acknowledge

  void acknowledge(ConsumerRecord<K,V> record, AcknowledgeType type)

  See Also:

  • KafkaShareConsumer.acknowledge(ConsumerRecord, AcknowledgeType)

• acknowledge

  void acknowledge(String topic, int partition, long offset, AcknowledgeType type)

  See Also:

  • KafkaShareConsumer.acknowledge(String, int, long, AcknowledgeType)

• commitSync

  Map<TopicIdPartition, Optional<KafkaException>> commitSync()

  See Also:

  • KafkaShareConsumer.commitSync()

• commitSync

  Map<TopicIdPartition, Optional<KafkaException>> commitSync(Duration timeout)

  See Also:

  • KafkaShareConsumer.commitSync(Duration)

• commitAsync

  void commitAsync()

  See Also:

  • KafkaShareConsumer.commitAsync()

• setAcknowledgementCommitCallback

  void setAcknowledgementCommitCallback(AcknowledgementCommitCallback callback)

  See Also:

  • KafkaShareConsumer.setAcknowledgementCommitCallback(AcknowledgementCommitCallback)

• clientInstanceId

  Uuid clientInstanceId(Duration timeout)

  See Also:

  • KafkaShareConsumer.clientInstanceId(Duration)

• acquisitionLockTimeoutMs

  Optional<Integer> acquisitionLockTimeoutMs()

  See Also:

  • KafkaShareConsumer.acquisitionLockTimeoutMs()

• metrics

  Map<MetricName, ? extends Metric> metrics()

  See Also:

  • KafkaShareConsumer.metrics()

• registerMetricForSubscription

  void registerMetricForSubscription(KafkaMetric metric)

  See Also:

  • KafkaShareConsumer.registerMetricForSubscription(KafkaMetric)

• unregisterMetricFromSubscription

  void unregisterMetricFromSubscription(KafkaMetric metric)

  See Also:

  • KafkaShareConsumer.unregisterMetricFromSubscription(KafkaMetric)

• close

  void close()

  Specified by:

  close in interface AutoCloseable

  Specified by:

  close in interface Closeable

  See Also:

  • KafkaShareConsumer.close()

• close

  void close(Duration timeout)

  See Also:

  • KafkaShareConsumer.close(Duration)

• wakeup

  void wakeup()

  See Also:

  • KafkaShareConsumer.wakeup()