Package io.confluent.ksql.api.client
Interface AcksPublisher
- All Superinterfaces:
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 TypeMethodDescriptionboolean
Returns whether theAcksPublisher
is complete.boolean
isFailed()
Returns whether theAcksPublisher
is failed.Methods inherited from interface org.reactivestreams.Publisher
subscribe
-
Method Details
-
isComplete
boolean isComplete()Returns whether theAcksPublisher
is complete.An
AcksPublisher
is complete if the HTTP connection associated with thisClient.streamInserts(java.lang.String, org.reactivestreams.Publisher<io.confluent.ksql.api.client.KsqlObject>)
request has been ended gracefully. Once complete, theAcksPublisher
will continue to deliver any remaining rows, then callonComplete()
on the subscriber, if present.- Returns:
- whether the
AcksPublisher
is complete.
-
isFailed
boolean isFailed()Returns whether theAcksPublisher
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 tosubscribe()
will be rejected.- Returns:
- whether the
AcksPublisher
is failed.
-