Interface PubSubProducerCallback

All Known Subinterfaces:
ChunkAwareCallback
All Known Implementing Classes:
AbstractPartitionWriter.ChildWriterProducerCallback, AbstractPartitionWriter.PartitionWriterProducerCallback, ActiveActiveProducerCallback, ChainedPubSubCallback, CompletableFutureCallback, LeaderProducerCallback, PubSubProducerCallbackSimpleImpl

public interface PubSubProducerCallback
A callback interface that users of PubSubProducerAdapter should implement if they want to execute some code once PubSubProducerAdapter#sendMessage request is completed.
  • Method Details

    • onCompletion

      void onCompletion(PubSubProduceResult produceResult, Exception exception)
      exception will be null if request was completed without an error.
    • setInternalCallback

      default void setInternalCallback(PubSubProducerCallback internalCallback)
      Add internal callback into the current callback. Default behavior is doing nothing.