CREATE TABLE IF NOT EXISTS `xxx_queue_分区id_message`(   `id` bigint UNSIGNED NOT_NULL COMMNET '消息id',   `message` text NOT NULL COMMENT '消息内容',   PRIMARY KEY ( `id` ))ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT '消息表';
CREATE TABLE IF NOT EXISTS `xxx_queue_consume_pos`(   `id` bigint UNSIGNED AUTO_INCREMENT COMMNET '主键id',   `consume_group` varchar(100) NOT NULL DEFAULT '' COMMENT '消费组',   `partition` int NOT NULL DEFAULT 0 COMMENT '分区编号',   `offset` bigint NOT NULL DEFAULT 0 COMMENT '消费的offset',   `ctime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',   `utime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',   PRIMARY KEY ( `id` ),   idx_consume_group_partition_offset(`consume_group`,`partition`,`offset`))ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT '消费进度表';