实时流存储fluss学习系列（四）Fluss分布式部署

分布式部署fluss的话，需要java版本为java17及以上。官方不推荐使用java8和java11。本演示用例部署的fluss集群是在三台服务器上进行部署，具体的集群信息如下：

1个coordinator server
多个tablet server

• 节点1：192.168.10.1

• 节点2：192.168.10.2

• 节点3：192.168.10.3

Node1会部署CoordinatorServer和一个TabletServer，Node2和Node3会部署一个TabletServer。

部署内容如下：

1、确保ZooKeeper已经部署，假设ZooKeeper的地址为192.168.10.99:2181

2、fluss官网下载最新版本的fluss：

tar -xzf fluss-0.5.0-bin.tgz
cd fluss-0.5.0/

3、node1编辑conf/server.yaml文件

coordinator.host: 192.168.10.1
coordinator.port: 9123
zookeeper.address: 192.168.10.99:2181
zookeeper.path.root: /fluss

tablet-server.host: 192.168.10.1
tablet-server.id: 1

4、node2编辑conf/server.yaml文件

zookeeper.address: 192.168.10.99:2181
zookeeper.path.root: /fluss

tablet-server.host: 192.168.10.2
tablet-server.id: 2

5、node3编辑conf/server.yaml文件

zookeeper.address: 192.168.10.99:2181
zookeeper.path.root: /fluss

tablet-server.host: 192.168.10.3
tablet-server.id: 3

6、在node1上启动CoordinatorServer

./bin/coordinator-server.sh start

7、在node1，node2，node3上启动TabletServer

./bin/tablet-server.sh start

集群启动后，就可以使用Fluss Client（目前仅支持 Flink Sql Client）与 Fluss 交互。在独立的flink集群种，把fluss的依赖jar添加到flink集群种，然后重启flink集群。

依赖下载地址：

https://alibaba.github.io/fluss-docs/downloads/

然后在flink集群种启动flink sql客户端，直接创建fluss的多数据源目录

CREATE CATALOG fluss_catalog WITH (
  'type'='fluss',
  'bootstrap.servers' = 'localhost:9123'
);

当看到提示成功之后，就可以进行创建表，插入数据，查询数据等操作了。