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 TypeMethodDescriptionlongseqNum()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
-