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 and 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

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

Method Detail

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