请问一下，如何创建Kafka加载consumer？

请问一下，如何创建Kafka加载consumer？
请问一下，如何创建Kafka加载consumer？

可使用
gbase> create kafka consumer kafka_load_testdb_tt1 loader topic gbase8a brokers '10.0.2.210:9092' duration 3000 into table testdb.tt1;
Query OK, 0 rows affected (Elapsed: 00:00:01.52)
create consumer done.