准备 Kafka 环境

本实践以 QingCloud Kafka 为例。

1. 创建 Kafka 集群。
2. 创建 Topic。

准备 ClickHouse 环境

本实践以 QingCloud ClickHouse 为例。

1. 创建 ClickHouse 集群。

2. 连接 ClickHouse。

3. 连接成功后，执行以下命令，创建数据库 pk。

   create database if not exists pk;
   

4. 执行以下命令，在数据库 pk 中创建数据库表 top_price。

   create table if not exists top_price(
       price Float64,
       supplier String,
       start DateTime,
       end   DateTime
   ) engine TinyLog;