如何在Memgraph mgconsole中操作Kafka流:启动/暂停/停止/删除
在Memgraph的mgconsole中操作Kafka流:启动、暂停、停止与删除
假设你已在Memgraph中创建了目标Kafka流(示例中流名称为my_kafka_stream),以下是具体操作命令:
启动Kafka流
启动指定流以开始摄入Kafka数据:
START STREAM my_kafka_stream;
若要启动所有已创建的Kafka流,执行:
START ALL STREAMS;
暂停Kafka流
暂停流会临时停止数据摄入,保留流的配置与状态,可随时恢复启动:
PAUSE STREAM my_kafka_stream;
暂停所有流的命令:
PAUSE ALL STREAMS;
停止Kafka流
停止流会终止数据摄入并重置流的消费状态(如偏移量):
STOP STREAM my_kafka_stream;
停止所有流的命令:
STOP ALL STREAMS;
删除Kafka流
删除流会彻底移除其配置与相关数据,操作不可恢复:
DROP STREAM my_kafka_stream;
删除所有流的命令:
DROP ALL STREAMS;
内容的提问来源于stack exchange,提问作者KWriter
相关产品推荐
相关产品推荐

