Skip to content

CommandStoreUtil

httpWaitForCommandSequenceNumber

void httpWaitForCommandSequenceNumber(
  CommandQueue commandQueue,
  KsqlRequest request,
  Duration timeout)

httpWaitForCommandSequenceNumber...FIXME


httpWaitForCommandSequenceNumber is used when:

waitForCommandSequenceNumber

void waitForCommandSequenceNumber(
  CommandQueue commandQueue,
  KsqlRequest request,
  Duration timeout)

waitForCommandSequenceNumber requests the given KsqlRequest for getCommandSequenceNumber and, only if the sequence number is specified, requests the given CommandQueue to ensureConsumedPast.


waitForCommandSequenceNumber is used when: