All Classes

Class	Description
AcksPublisher	A Reactive Streams Publisher that publishes server acknowledgments for rows inserted into an existing ksqlDB stream via Client.streamInserts(String, Publisher).
BatchedQueryResult	The result of a query (push or pull), returned as a single batch once the query has finished executing, or the query has been terminated.
Client	A client that connects to a specific ksqlDB server.
ClientOptions	Options for the ksqlDB Client.
ColumnType	The type of a column returned as part of a query result.
ColumnType.Type
ExecuteStatementResult	The result of executing a 'CREATE', 'CREATE ...
FieldInfo	Represents a field/column of a ksqlDB stream/table.
InsertAck	An acknowledgment from the ksqlDB server that a row has been successfully inserted into a ksqlDB stream.
InsertsPublisher	A org.reactivestreams.Publisher suitable for use with the Client.streamInserts(String, Publisher) method.
KsqlArray	A representation of an array of values.
KsqlClientException
KsqlException	Converts KsqlErrorMessage into an exception to be passed to client exception handlers.
KsqlObject	A representation of a map of string keys to values.
QueryInfo	Metadata for a ksqlDB query.
QueryInfo.QueryType
Row	A single record, returned as part of a query result.
SourceDescription	Metadata for a ksqlDB stream or table.
StreamedQueryResult	The result of a query (push or pull), streamed one row at time.
StreamInfo	Metadata for a ksqlDB stream.
TableInfo	Metadata for a ksqlDB table.
TopicInfo	Metadata for a Kafka topic available for use with ksqlDB.