Package io.confluent.ksql.api.client
Interface InsertAck
-
public interface InsertAck
An acknowledgment from the ksqlDB server that a row has been successfully inserted into a ksqlDB stream. SeeClient.streamInserts(String, Publisher)
for details.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description long
seqNum()
Returns the corresponding sequence number for this acknowledgment.
-
-
-
Method Detail
-
seqNum
long seqNum()
Returns the corresponding sequence number for this acknowledgment. Sequence numbers start at zero for each newClient.streamInserts(java.lang.String, org.reactivestreams.Publisher<io.confluent.ksql.api.client.KsqlObject>)
request.- Returns:
- the sequence number
-
-