Package io.confluent.license

Class LicenseStore.ConsumeCallback

java.lang.Object
io.confluent.license.LicenseStore.ConsumeCallback
All Implemented Interfaces:
Callback<org.apache.kafka.clients.consumer.ConsumerRecord<io.confluent.command.record.Command.CommandKey,io.confluent.command.record.Command.CommandMessage>>
Enclosing class:
LicenseStore
public static class LicenseStore.ConsumeCallback extends Object implements Callback<org.apache.kafka.clients.consumer.ConsumerRecord<io.confluent.command.record.Command.CommandKey,io.confluent.command.record.Command.CommandMessage>>

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onCompletion(Throwable error, org.apache.kafka.clients.consumer.ConsumerRecord<io.confluent.command.record.Command.CommandKey,io.confluent.command.record.Command.CommandMessage> record)
    Invoked upon completion of the operation.

    Methods inherited from class java.lang.Object

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

  • Method Details

    • onCompletion

      public void onCompletion(Throwable error, org.apache.kafka.clients.consumer.ConsumerRecord<io.confluent.command.record.Command.CommandKey,io.confluent.command.record.Command.CommandMessage> record)
      Description copied from interface: Callback
      Invoked upon completion of the operation.
      Specified by:
      onCompletion in interface Callback<org.apache.kafka.clients.consumer.ConsumerRecord<io.confluent.command.record.Command.CommandKey,io.confluent.command.record.Command.CommandMessage>>
      Parameters:
      error - the error that caused the operation to fail, or null if no error occurred
      record - the return value, or null if the operation failed