Package io.confluent.ksql.api.client
package io.confluent.ksql.api.client
-
ClassDescriptionA Reactive Streams Publisher that publishes server acknowledgments for rows inserted into an existing ksqlDB stream via
Client.streamInserts(String, Publisher)
.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.A client that connects to a specific ksqlDB server.Instances ofClient.HttpRequest
are used to make direct HTTP requests to ksqlDB server's REST API.Options for the ksqlDBClient
.The type of a column returned as part of a query result.The result of executing a 'CREATE', 'CREATE ...Represents a field/column of a ksqlDB stream/table.An acknowledgment from the ksqlDB server that a row has been successfully inserted into a ksqlDB stream.Aorg.reactivestreams.Publisher
suitable for use with theClient.streamInserts(String, Publisher)
method.A representation of an array of values.A representation of a map of string keys to values.Metadata for a ksqlDB query.A single record, returned as part of a query result.Metadata for a ksqlDB server.Metadata for a ksqlDB stream or table.The result of a query (push or pull), streamed one row at time.Metadata for a ksqlDB stream.Metadata for a ksqlDB table.Metadata for a Kafka topic available for use with ksqlDB.