Interface AcksPublisher

  • All Superinterfaces:
    org.reactivestreams.Publisher<InsertAck>

    public interface AcksPublisher
    extends org.reactivestreams.Publisher<InsertAck>
    A Reactive Streams Publisher that publishes server acknowledgments for rows inserted into an existing ksqlDB stream via Client.streamInserts(String, Publisher).
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      boolean isComplete()
      Returns whether the AcksPublisher is complete.
      boolean isFailed()
      Returns whether the AcksPublisher is failed.
      • Methods inherited from interface org.reactivestreams.Publisher

        subscribe
    • Method Detail

      • isFailed

        boolean isFailed()
        Returns whether the AcksPublisher is failed.

        An AcksPublisher is failed if an error is received from the server. Once failed, onError() is called on the subscriber, if present, and new calls to subscribe() will be rejected.

        Returns:
        whether the AcksPublisher is failed.