mirror of
https://github.com/didi/KnowStreaming.git
synced 2025-12-24 11:52:08 +08:00
补充Kafka-Group表
This commit is contained in:
@@ -7,6 +7,8 @@
|
|||||||
|
|
||||||
### 6.2.0、升级至 `master` 版本
|
### 6.2.0、升级至 `master` 版本
|
||||||
|
|
||||||
|
**SQL 变更**
|
||||||
|
|
||||||
```sql
|
```sql
|
||||||
DROP TABLE IF EXISTS `ks_km_zookeeper`;
|
DROP TABLE IF EXISTS `ks_km_zookeeper`;
|
||||||
CREATE TABLE `ks_km_zookeeper` (
|
CREATE TABLE `ks_km_zookeeper` (
|
||||||
@@ -22,8 +24,29 @@ CREATE TABLE `ks_km_zookeeper` (
|
|||||||
PRIMARY KEY (`id`),
|
PRIMARY KEY (`id`),
|
||||||
UNIQUE KEY `uniq_cluster_phy_id_host_port` (`cluster_phy_id`,`host`, `port`)
|
UNIQUE KEY `uniq_cluster_phy_id_host_port` (`cluster_phy_id`,`host`, `port`)
|
||||||
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='Zookeeper信息表';
|
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='Zookeeper信息表';
|
||||||
|
|
||||||
|
|
||||||
|
DROP TABLE IF EXISTS `ks_km_group`;
|
||||||
|
CREATE TABLE `ks_km_group` (
|
||||||
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
|
||||||
|
`cluster_phy_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '集群id',
|
||||||
|
`name` varchar(192) COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'Group名称',
|
||||||
|
`member_count` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '成员数',
|
||||||
|
`topic_members` text CHARACTER SET utf8 COMMENT 'group消费的topic列表',
|
||||||
|
`partition_assignor` varchar(255) CHARACTER SET utf8 NOT NULL COMMENT '分配策略',
|
||||||
|
`coordinator_id` int(11) NOT NULL COMMENT 'group协调器brokerId',
|
||||||
|
`type` int(11) NOT NULL COMMENT 'group类型 0:consumer 1:connector',
|
||||||
|
`state` varchar(64) CHARACTER SET utf8 NOT NULL DEFAULT '' COMMENT '状态',
|
||||||
|
`create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
||||||
|
`update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
||||||
|
PRIMARY KEY (`id`),
|
||||||
|
UNIQUE KEY `uniq_cluster_phy_id_name` (`cluster_phy_id`,`name`)
|
||||||
|
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='Group信息表';
|
||||||
|
|
||||||
```
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
|
||||||
### 6.2.1、升级至 `v3.0.0` 版本
|
### 6.2.1、升级至 `v3.0.0` 版本
|
||||||
|
|
||||||
|
|||||||
@@ -371,3 +371,21 @@ CREATE TABLE `ks_km_zookeeper` (
|
|||||||
PRIMARY KEY (`id`),
|
PRIMARY KEY (`id`),
|
||||||
UNIQUE KEY `uniq_cluster_phy_id_host_port` (`cluster_phy_id`,`host`, `port`)
|
UNIQUE KEY `uniq_cluster_phy_id_host_port` (`cluster_phy_id`,`host`, `port`)
|
||||||
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='Zookeeper信息表';
|
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='Zookeeper信息表';
|
||||||
|
|
||||||
|
|
||||||
|
DROP TABLE IF EXISTS `ks_km_group`;
|
||||||
|
CREATE TABLE `ks_km_group` (
|
||||||
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
|
||||||
|
`cluster_phy_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '集群id',
|
||||||
|
`name` varchar(192) COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'Group名称',
|
||||||
|
`member_count` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '成员数',
|
||||||
|
`topic_members` text CHARACTER SET utf8 COMMENT 'group消费的topic列表',
|
||||||
|
`partition_assignor` varchar(255) CHARACTER SET utf8 NOT NULL COMMENT '分配策略',
|
||||||
|
`coordinator_id` int(11) NOT NULL COMMENT 'group协调器brokerId',
|
||||||
|
`type` int(11) NOT NULL COMMENT 'group类型 0:consumer 1:connector',
|
||||||
|
`state` varchar(64) CHARACTER SET utf8 NOT NULL DEFAULT '' COMMENT '状态',
|
||||||
|
`create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
||||||
|
`update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
||||||
|
PRIMARY KEY (`id`),
|
||||||
|
UNIQUE KEY `uniq_cluster_phy_id_name` (`cluster_phy_id`,`name`)
|
||||||
|
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='Group信息表';
|
||||||
Reference in New Issue
Block a user