如何使用带有控制台/命令行/cli 的 Confluent KSQLDB 在 KAFKA 中创建 table？

Question

我正在尝试使用 Confluent 的 KSQLDB 在 KAFKA 中创建一个 table。我很容易使用 Confluent 提供的用户体验，但我正在尝试自动化这个过程，因此 我需要一个命令行 scipting 功能来执行这个任务。

我已经能够使用 Confluent 的 KSQLDB REST 接口为简单命令（“LIST STREAMS”）执行 curl，但是更复杂的语句，例如创建 table，似乎不可用，或者有clone/use.

没有可用的示例

有没有人有命令行脚本或知道控制台命令来创建 KSQLDB table（在 Confluent 的 Kafka 版本中）？

Answer 1

您可以使用/ksql endpoint。例如：

curl -s -X "POST" "http://localhost:8088/ksql" \
     -H "Content-Type: application/vnd.ksql.v1+json; charset=utf-8" \
     -d '{"ksql":"CREATE TABLE MOVEMENTS (PERSON VARCHAR KEY, LOCATION VARCHAR) WITH (VALUE_FORMAT='\''JSON'\'', KAFKA_TOPIC='\''movements'\'');"}'

如何使用带有控制台/命令行/cli 的 Confluent KSQLDB 在 KAFKA 中创建 table？

How to create a table in KAFKA using Confluent KSQLDB with a console / command line / cli?

apache-kafka

confluent-platform

ksqldb