public static class LicenseStore.ConsumeCallback extends Object implements org.apache.kafka.connect.util.Callback<org.apache.kafka.clients.consumer.ConsumerRecord<io.confluent.command.record.Command.CommandKey,io.confluent.command.record.Command.CommandMessage>>
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) |
public void onCompletion(Throwable error, org.apache.kafka.clients.consumer.ConsumerRecord<io.confluent.command.record.Command.CommandKey,io.confluent.command.record.Command.CommandMessage> record)
onCompletion
in interface org.apache.kafka.connect.util.Callback<org.apache.kafka.clients.consumer.ConsumerRecord<io.confluent.command.record.Command.CommandKey,io.confluent.command.record.Command.CommandMessage>>