Skip to main content

KAFKA.COMMAND

Allows KSQL commands to be used. You can use the Function Wizard for this function.

Syntax

=KAFKA.COMMAND(Producer, Command, Target [, Timeout])

Arguments

NameDescription
ProducerProducer to use.
CommandAny command allowed in KSQL table.
TargetINBOX(), OUTBOX("MsgID") or a cell range where the result will be placed. Make sure the cell range is big enough or not everything is displayed.
TimeoutOptional. The time to wait for an answer. When left empty a 20 second timeout is being used.

Return Value

TRUE, if no error.

Examples

FunctionResultComment
=KAFKA.COMMAND(|Kafka Producer, "CREATE TABLE ksqltable201 (random BIGINT, type VARCHAR) WITH (kafka_topic='cedalo', value_format='JSON', key = 'random')", INBOX ())TRUEA KSQL table will be created with the name ksqltable201.