Kafka Sql：简单使用

---

Confluent:5.3.1

Confluent安装：https://blog.csdn.net/u012551524/article/details/103686739

kafka:2.0.0

---

1、修改配置文件/data/software/confluent-5.3.1/etc/ksql/ksql-server.properties

bootstrap.servers=bigdata-dev1:9092,bigdata-dev2:9092,bigdata-dev3:9092

2、启动ksql server

/data/software/confluent-5.3.1/bin/ksql-server-start   /data/software/confluent-5.3.1/etc/ksql/ksql-server.properties

3、启动KSQL CLI

LOG_DIR=/tmp/ksql_logs /data/software/confluent-5.3.1/bin/ksql http://localhost:8088

4、创建一张表

CREATE STREAM action_log
(ID STRING, 
WRITE_DATE STRING, 
NAME STRING) with 
(kafka_topic='action.log',value_format='DELIMITED');

5、产看表action_log

select id,WRITE_DATE,NAME from action_log;

6、创建一个producer向topic action.log写测试数据

7、ksql cli端查看