Package io.confluent.ksql.api.client

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

    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 Details

    • isComplete

      boolean isComplete()
      Returns whether the AcksPublisher is complete.

      An AcksPublisher is complete if the HTTP connection associated with this Client.streamInserts(java.lang.String, org.reactivestreams.Publisher<io.confluent.ksql.api.client.KsqlObject>) request has been ended gracefully. Once complete, the AcksPublisher will continue to deliver any remaining rows, then call onComplete() on the subscriber, if present.

      Returns:
      whether the AcksPublisher is complete.

    • 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.