功能说明
启动指定的consumer task，该consumer task 开始从kafka 读取数据并同步入库。
启动需保证consumer task 已存在且有效，并且gcluster_kafka_consumer_enable 值
为1。
Kafka consumer 支持断点续传和重复消息筛除。
断点续传即consumer task 停止又启动后，
会自动从上一次同步完成的位置开始继
续同步。
GBase 8a MPP Cluster 产品手册
5 数据库管理指南
文档版本953（2022-04-10）
南大通用数据技术股份有限公司
1279
筛除重复消息即筛查重复的消息，将重复的消息删除。该功能可以通过集群参数
进行配置，如果开启筛除重复消息，性能相对关闭该功能会有所下降，如果关闭
该功能，需用户程序来保证向kafka 发布的消息无重复。
consumer task 调度机制会确保consumer task 的高可用和负载均衡。
所有已经启动
的consumer task，其运行在哪个节点是由consumer task 任务调度线程来分配的，
所以consumer task 不一定运行在执行命令所在的节点，可以通过查看consumer
task 运行状态来获得其运行在哪个节点（IP 地址）。
在consumer task 运行期间，只要用户没有执行stop 命令停止consumer task，
consumer task 将持续运行，即使集群服务全部stop 后再次start 时，consumer task
也会自动继续运行。
语法格式
启动指定的consumer task
START KAFKA CONSUMER
启动所有的transaction topic consumer
START KAFKA TRANSACTION CONSUMER;