PipelineDB-Kafka删除配置的broker

前几天在添加broker时候，配置错了，需要删除，

add命令很简单，类似这样的

SELECT pipeline_kafka.add_broker('localhost:9092');

不过文档里没看到删掉的命令，文档里也没有，

后来在 https://githubcom/pipelinedb/pipeline_kafka/pipeline_kafka--0.9.3.sql

找到如下定义

CREATE FUNCTION pipeline_kafka.remove_broker (              

  host text)

RETURNS text

AS 'MODULE_PATHNAME', 'kafka_remove_broker'

LANGUAGE C IMMUTABLE;

具体执行如下语句即可

SELECT pipeline_kafka.remove_broker('localhost:9092');