Interface Summary Interface Description AcksPublisherA Reactive Streams Publisher that publishes server acknowledgments for rows inserted into an existing ksqlDB stream via
ClientA client that connects to a specific ksqlDB server. Client.HttpRequestInstances of
Client.HttpRequestare used to make direct HTTP requests to ksqlDB server's REST API.
Client.HttpResponse ClientOptionsOptions for the ksqlDB
ColumnTypeThe type of a column returned as part of a query result. ConnectorDescription ConnectorInfo ConnectorType ExecuteStatementResultThe result of executing a 'CREATE', 'CREATE ... FieldInfoRepresents a field/column of a ksqlDB stream/table. InsertAckAn acknowledgment from the ksqlDB server that a row has been successfully inserted into a ksqlDB stream. QueryInfoMetadata for a ksqlDB query. RowA single record, returned as part of a query result. ServerInfoMetadata for a ksqlDB server. SourceDescriptionMetadata for a ksqlDB stream or table. StreamedQueryResultThe result of a query (push or pull), streamed one row at time. StreamInfoMetadata for a ksqlDB stream. TableInfoMetadata for a ksqlDB table. TopicInfoMetadata for a Kafka topic available for use with ksqlDB.
Class Summary Class Description BatchedQueryResultThe result of a query (push or pull), returned as a single batch once the query has finished executing, or the query has been terminated. InsertsPublisherA
org.reactivestreams.Publishersuitable for use with the
KsqlArrayA representation of an array of values. KsqlObjectA representation of a map of string keys to values.
Enum Summary Enum Description ColumnType.Type ConnectorType.Type QueryInfo.QueryType