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

Name	Description
Producer	Producer to use.
Command	Any command allowed in KSQL table.
Target	INBOX(), 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.
Timeout (optional)	The time to wait for an answer. When left empty a 20 second timeout is being used.

Return

TRUE, if no error.

Examples

Formula	Result	Comment
=KAFKA.COMMAND(|KafkaProducer, "CREATE TABLE ksqltable201 (random BIGINT, type VARCHAR) WITH (kafka_topic='cedalo', value_format='JSON', key = 'random')", INBOX ())	TRUE	A KSQL table will be created with the name ksqltable201.