gbase读取带压缩的 zstd kafka-topic入库

1.当前版本

2.新建topic 指定压缩：

bin/kafka-topics.sh --create --topic BL_MAINT2026 --bootstrap-server 172.16.6.230:9092 --partitions 1 --replication-factor 3 --config compression.type=zstd

查看topic :  bin/kafka-topics.sh --describe --topic BL_MAINT2026 --bootstrap-server 172.16.6.230:9092

3.启动生产者：

bin/kafka-console-producer.sh --topic BL_MAINT2026 --bootstrap-server 172.16.6.230:9092,172.16.6.231:9092,172.16.6.232:9092

4.启动消费者

5.设置参数，启动任务

否则报错： 

ERROR 1707 (HY000): gcluster command error: gnode parameter "_gbase_kafka_transaction_mode" must be ON (172.16.6.230, 172.16.6.231, 172.16.6.232)

查询结果表：