Class MockShareConsumer<K,V>

Method Details

• subscription

  public Set<String> subscription()

  Specified by:

  subscription in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.subscription()

• subscribe

  public void subscribe(Collection<String> topics)

  Specified by:

  subscribe in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.subscribe(Collection)

• unsubscribe

  public void unsubscribe()

  Specified by:

  unsubscribe in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.unsubscribe()

• poll

  public ConsumerRecords<K,V> poll(Duration timeout)

  Specified by:

  poll in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.poll(Duration)

• acknowledge

  public void acknowledge(ConsumerRecord<K,V> record)

  Specified by:

  acknowledge in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.acknowledge(ConsumerRecord)

• acknowledge

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

  Specified by:

  acknowledge in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.acknowledge(ConsumerRecord, AcknowledgeType)

• commitSync

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

  Specified by:

  commitSync in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.commitSync()

• commitSync

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

  Specified by:

  commitSync in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.commitSync(Duration)

• commitAsync

  public void commitAsync()

  Specified by:

  commitAsync in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.commitAsync()

• setAcknowledgementCommitCallback

  public void setAcknowledgementCommitCallback(AcknowledgementCommitCallback callback)

  Specified by:

  setAcknowledgementCommitCallback in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.setAcknowledgementCommitCallback(AcknowledgementCommitCallback)

• setClientInstanceId

  public void setClientInstanceId(Uuid clientInstanceId)

• clientInstanceId

  public Uuid clientInstanceId(Duration timeout)

  Specified by:

  clientInstanceId in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.clientInstanceId(Duration)

• metrics

  public Map<MetricName,? extends Metric> metrics()

  Specified by:

  metrics in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.metrics()

• registerMetricForSubscription

  public void registerMetricForSubscription(KafkaMetric metric)

  Specified by:

  registerMetricForSubscription in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.registerMetricForSubscription(KafkaMetric)

• unregisterMetricFromSubscription

  public void unregisterMetricFromSubscription(KafkaMetric metric)

  Specified by:

  unregisterMetricFromSubscription in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.unregisterMetricFromSubscription(KafkaMetric)

• close

  public void close()

  Specified by:

  close in interface AutoCloseable

  Specified by:

  close in interface Closeable

  Specified by:

  close in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.close()

• close

  public void close(Duration timeout)

  Specified by:

  close in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.close(Duration)

• wakeup

  public void wakeup()

  Specified by:

  wakeup in interface ShareConsumer<K,V>

  See Also:

  • KafkaShareConsumer.wakeup()

• addRecord

  public void addRecord(ConsumerRecord<K,V> record)