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. See
Client.streamInserts(String, Publisher)
for details.-
Method Summary
Modifier and TypeMethodDescriptionlong
seqNum()
Returns the corresponding sequence number for this acknowledgment.
-
Method Details
-
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
-