AcksPublisher (ksqldb-api-client 0.23.1 API)

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