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.
TargetTarget to show the result of the command operation. Can be either INBOX(), OUTBOX() or a cell range.
TimeoutOptional. The time to wait for an answer. When left empty a 20 second timeout is being used.

Return Value

TRUE, if successful.

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.