Class MockConsumer<K,V>

Method Details

• assignment

  public Set<TopicPartition> assignment()

  Specified by:

  assignment in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.assignment()

• rebalance

  public void rebalance(Collection<TopicPartition> newAssignment)

  Simulate a rebalance event.

• subscription

  public Set<String> subscription()

  Specified by:

  subscription in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.subscription()

• subscribe

  public void subscribe(Collection<String> topics)

  Specified by:

  subscribe in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.subscribe(Collection)

• subscribe

  public void subscribe(Pattern pattern, ConsumerRebalanceListener listener)

  Specified by:

  subscribe in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.subscribe(Pattern, ConsumerRebalanceListener)

• subscribe

  public void subscribe(Pattern pattern)

  Specified by:

  subscribe in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.subscribe(Pattern)

• subscribe

  public void subscribe(SubscriptionPattern pattern, ConsumerRebalanceListener listener)

  Specified by:

  subscribe in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.subscribe(SubscriptionPattern, ConsumerRebalanceListener)

• subscribe

  public void subscribe(SubscriptionPattern pattern)

  Specified by:

  subscribe in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.subscribe(SubscriptionPattern)

• subscribe

  public void subscribe(Collection<String> topics, ConsumerRebalanceListener listener)

  Specified by:

  subscribe in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.subscribe(Collection, ConsumerRebalanceListener)

• registerMetricForSubscription

  public void registerMetricForSubscription(KafkaMetric metric)

  Specified by:

  registerMetricForSubscription in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.registerMetricForSubscription(KafkaMetric)

• unregisterMetricFromSubscription

  public void unregisterMetricFromSubscription(KafkaMetric metric)

  Specified by:

  unregisterMetricFromSubscription in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.unregisterMetricFromSubscription(KafkaMetric)

• assign

  public void assign(Collection<TopicPartition> partitions)

  Specified by:

  assign in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.assign(Collection)

• unsubscribe

  public void unsubscribe()

  Specified by:

  unsubscribe in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.unsubscribe()

• poll

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

  Specified by:

  poll in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.poll(Duration)

• addRecord

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

• setMaxPollRecords

  public void setMaxPollRecords(long maxPollRecords)

  Sets the maximum number of records returned in a single call to poll(Duration).

  Parameters:

  maxPollRecords - the max.poll.records.

• setPollException

  public void setPollException(KafkaException exception)

• setOffsetsException

  public void setOffsetsException(KafkaException exception)

• setPositionException

  public void setPositionException(KafkaException exception)

• commitAsync

  public void commitAsync(Map<TopicPartition, OffsetAndMetadata> offsets, OffsetCommitCallback callback)

  Specified by:

  commitAsync in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.commitAsync(Map, OffsetCommitCallback)

• commitSync

  public void commitSync(Map<TopicPartition, OffsetAndMetadata> offsets)

  Specified by:

  commitSync in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.commitSync(Map)

• commitAsync

  public void commitAsync()

  Specified by:

  commitAsync in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.commitAsync()

• commitAsync

  public void commitAsync(OffsetCommitCallback callback)

  Specified by:

  commitAsync in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.commitAsync(OffsetCommitCallback)

• commitSync

  public void commitSync()

  Specified by:

  commitSync in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.commitSync()

• commitSync

  public void commitSync(Duration timeout)

  Specified by:

  commitSync in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.commitSync(Duration)

• commitSync

  public void commitSync(Map<TopicPartition, OffsetAndMetadata> offsets, Duration timeout)

  Specified by:

  commitSync in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.commitSync(Map, Duration)

• seek

  public void seek(TopicPartition partition, long offset)

  Specified by:

  seek in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.seek(TopicPartition, long)

• seek

  public void seek(TopicPartition partition, OffsetAndMetadata offsetAndMetadata)

  Specified by:

  seek in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.seek(TopicPartition, OffsetAndMetadata)

• committed

  public Map<TopicPartition, OffsetAndMetadata> committed(Set<TopicPartition> partitions)

  Specified by:

  committed in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.committed(Set)

• committed

  public Map<TopicPartition, OffsetAndMetadata> committed(Set<TopicPartition> partitions, Duration timeout)

  Specified by:

  committed in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.committed(Set, Duration)

• position

  public long position(TopicPartition partition)

  Specified by:

  position in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.position(TopicPartition)

• position

  public long position(TopicPartition partition, Duration timeout)

  Specified by:

  position in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.position(TopicPartition, Duration)

• seekToBeginning

  public void seekToBeginning(Collection<TopicPartition> partitions)

  Specified by:

  seekToBeginning in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.seekToBeginning(Collection)

• updateBeginningOffsets

  public void updateBeginningOffsets(Map<TopicPartition, Long> newOffsets)

• seekToEnd

  public void seekToEnd(Collection<TopicPartition> partitions)

  Specified by:

  seekToEnd in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.seekToEnd(Collection)

• updateEndOffsets

  public void updateEndOffsets(Map<TopicPartition, Long> newOffsets)

• updateDurationOffsets

  public void updateDurationOffsets(Map<TopicPartition, Long> newOffsets)

• disableTelemetry

  public void disableTelemetry()

• injectTimeoutException

  public void injectTimeoutException(int injectTimeoutExceptionCounter)

  Parameters:

  injectTimeoutExceptionCounter - use -1 for infinite

• setClientInstanceId

  public void setClientInstanceId(Uuid instanceId)

• clientInstanceId

  public Uuid clientInstanceId(Duration timeout)

  Description copied from interface: Consumer

  See KafkaConsumer.clientInstanceId(Duration)}

  Specified by:

  clientInstanceId in interface Consumer<K,V>

• metrics

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

  Specified by:

  metrics in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.metrics()

• partitionsFor

  public List<PartitionInfo> partitionsFor(String topic)

  Specified by:

  partitionsFor in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.partitionsFor(String)

• listTopics

  public Map<String, List<PartitionInfo>> listTopics()

  Specified by:

  listTopics in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.listTopics()

• updatePartitions

  public void updatePartitions(String topic, List<PartitionInfo> partitions)

• pause

  public void pause(Collection<TopicPartition> partitions)

  Specified by:

  pause in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.pause(Collection)

• resume

  public void resume(Collection<TopicPartition> partitions)

  Specified by:

  resume in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.resume(Collection)

• offsetsForTimes

  public Map<TopicPartition, OffsetAndTimestamp> offsetsForTimes(Map<TopicPartition, Long> timestampsToSearch)

  Specified by:

  offsetsForTimes in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.offsetsForTimes(Map)

• beginningOffsets

  public Map<TopicPartition, Long> beginningOffsets(Collection<TopicPartition> partitions)

  Specified by:

  beginningOffsets in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.beginningOffsets(Collection)

• endOffsets

  public Map<TopicPartition, Long> endOffsets(Collection<TopicPartition> partitions)

  Specified by:

  endOffsets in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.endOffsets(Collection)

• close

  public void close()

  Specified by:

  close in interface AutoCloseable

  Specified by:

  close in interface Closeable

  Specified by:

  close in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.close()

• close

  @Deprecatedpublic void close(Duration timeout)

  Deprecated.

  Specified by:

  close in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.close(Duration)

• closed

  public boolean closed()

• wakeup

  public void wakeup()

  Specified by:

  wakeup in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.wakeup()

• close

  public void close(CloseOptions option)

  Specified by:

  close in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.close(CloseOptions)

• schedulePollTask

  public void schedulePollTask(Runnable task)

  Schedule a task to be executed during a poll(). One enqueued task will be executed per poll(Duration) invocation. You can use this repeatedly to mock out multiple responses to poll invocations.

  Parameters:

  task - the task to be executed

• scheduleNopPollTask

  public void scheduleNopPollTask()

• paused

  public Set<TopicPartition> paused()

  Specified by:

  paused in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.paused()

• partitionsFor

  public List<PartitionInfo> partitionsFor(String topic, Duration timeout)

  Specified by:

  partitionsFor in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.partitionsFor(String, Duration)

• listTopics

  public Map<String, List<PartitionInfo>> listTopics(Duration timeout)

  Specified by:

  listTopics in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.listTopics(Duration)

• offsetsForTimes

  public Map<TopicPartition, OffsetAndTimestamp> offsetsForTimes(Map<TopicPartition, Long> timestampsToSearch, Duration timeout)

  Specified by:

  offsetsForTimes in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.offsetsForTimes(Map, Duration)

• beginningOffsets

  public Map<TopicPartition, Long> beginningOffsets(Collection<TopicPartition> partitions, Duration timeout)

  Specified by:

  beginningOffsets in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.beginningOffsets(Collection, Duration)

• endOffsets

  public Map<TopicPartition, Long> endOffsets(Collection<TopicPartition> partitions, Duration timeout)

  Specified by:

  endOffsets in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.endOffsets(Collection, Duration)

• currentLag

  public OptionalLong currentLag(TopicPartition topicPartition)

  Specified by:

  currentLag in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.currentLag(TopicPartition)

• groupMetadata

  public ConsumerGroupMetadata groupMetadata()

  Specified by:

  groupMetadata in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.groupMetadata()

• enforceRebalance

  public void enforceRebalance()

  Specified by:

  enforceRebalance in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.enforceRebalance()

• enforceRebalance

  public void enforceRebalance(String reason)

  Specified by:

  enforceRebalance in interface Consumer<K,V>

  See Also:

  • KafkaConsumer.enforceRebalance(String)

• shouldRebalance

  public boolean shouldRebalance()

• resetShouldRebalance

  public void resetShouldRebalance()

• lastPollTimeout

  public Duration lastPollTimeout()

• addedMetrics

  public List<KafkaMetric> addedMetrics()