可使用

gbase> show kafka consumer kafka_load_testdb_tt1;
+-----------------------+------+--------+-------+---------+-----------------+------------+----------+----------------+--------+
| NAME | TYPE | DB | TABLE | TOPIC | BROKERS | PARTITIONS | DURATION | LOADER_OPTIONS | STATUS |
+-----------------------+------+--------+-------+---------+-----------------+------------+----------+----------------+--------+
| kafka_load_testdb_tt1 | L | testdb | tt1 | gbase8a | 10.0.2.210:9092 | ALL | 3000 | DATA_FORMAT 3 | start |
+-----------------------+------+--------+-------+---------+-----------------+------------+----------+----------------+--------+
1 row in set (Elapsed: 00:00:00.22)

来查看消费者状态。