A Kafka topic listed in the Kafka() engine's kafka_topic_list parameter. ClickHouse opens a consumer (or kafka_num_consumers parallel consumers) against this topic under the consumer group named in kafka_group_name and decodes each message using the format named in kafka_format.
kafka_topic — Name of the Kafka topic being consumed
Operations
receive
consumeFromKafka
ClickHouse, on behalf of a CREATE TABLE ... ENGINE = Kafka(...) definition, polls the configured topic(s) and decodes each record according to kafka_format. A downstream MATERIALIZED VIEW typically mo
Messages
KafkaRecord
A single Kafka record consumed by the ClickHouse Kafka engine and exposed as a row with virtual columns.
Content-Type: application/octet-stream
About AsyncAPI
The AsyncAPI specification describes event-driven APIs the way OpenAPI describes request/response APIs. A channel is the named pipe — a webhook URL, a Kafka topic, a WebSocket route, an MQTT subject — that producers and consumers publish or subscribe to. Each channel carries one or more messages with structured payloads, and an operation declares whether a given party sends or receives on that channel.
Discovery needs no key. Ratings and market analysis are Pro.
Get an API key
Free tier, no form to fill in. Signing in shares your email address with us — we
store it to create your key and to recognise you if you sign in with another
provider. See our Privacy Policy and
Terms.