Method Detail

• onComplete

  void onComplete(Map<TopicIdPartition,Set<Long>> offsets,
                  Exception exception)

  A callback method the user can implement to provide asynchronous handling of acknowledgement completion. This method will be called when the acknowledgement request sent to the server has been completed.

  Parameters:

  offsets - A map of the offsets that this callback applies to.

  exception - The exception thrown during processing of the request, or null if the acknowledgement completed successfully.

  • InvalidRecordStateException if the record state is invalid
  • AuthorizationException if not authorized to the topic of group
  • WakeupException if KafkaShareConsumer.wakeup() is called before or while this function is called
  • InterruptException if the calling thread is interrupted before or while this function is called
  • KafkaException for any other unrecoverable errors