Package com.linkedin.venice.pubsub.api

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.