Package io.confluent.ksql.api.client

Interface ExecuteStatementResult

public interface ExecuteStatementResult
The result of executing a 'CREATE', 'CREATE ... AS * SELECT', 'DROP', 'TERMINATE', or 'INSERT INTO ... AS SELECT' statement on the ksqlDB server.

  • Method Summary

    Modifier and Type
    Method
    Description
    Optional<String>
    queryId()
    Returns the ID of a newly started persistent query, if applicable.

  • Method Details

    • queryId

      Optional<String> queryId()
      Returns the ID of a newly started persistent query, if applicable. The return value is empty for all statements other than 'CREATE ... AS * SELECT' and 'INSERT * INTO ... AS SELECT' statements, as only these statements start persistent queries. For statements that start persistent queries, the return value may still be empty if either:

      • The statement was not executed on the server by the time the server response was sent. This typically does not happen under normal server operation, but may happen if the ksqlDB server's command runner thread is stuck, or if the configured value for ksql.server.command.response.timeout.ms is too low
      • The ksqlDB server version is lower than 0.11.0.
      Returns:
      the query ID, if applicable