gbase 同步kafka consumers状态

项目需要把旧集群卸载，重新安装新集群。为保障kafka consumer消费在新旧集群的一致性，需要将旧集群kafka consumer相关信息同步至新集群。

操作步骤
获取旧集群kafka consumer name,topic,brokers信息
Select name,topic,brokers from gclusterdb.kafka_consumers;

停止旧集群consumer task
Stop kafka consumer xx;
获取consumer maxoffset 及pos信息
Select offset,pos from gclusterdb.kafka_consumer_offset_xx where offset=(select max(offset) from kafka_consumer_offset_xx;

新集群创建consumer task
Create kafka consumer xx transaction topic xx brokers ‘$brokers’;
更新新集群consumer maxoffset 及pos信息
Insert into gclusterdb.kafka_consumer_offset_xx values(xxx, xxx);

Flush table gclusterdb.kafka_consumer_offset_xxx
启动新集群consumer task
Start kafka consumer xxx。