Kafka Connect-如何删除连接器

问题描述 投票:5回答:2

我在connector.properties文件中做了一些更改之后创建了一个cassandra-sink连接器。在停止工作程序并重新启动它之后,现在当我使用以下命令添加连接器时:

java -jar kafka-connect-cli-1.0.6-all.jar create cassandra-sink-orders < cassandra-sink-distributed-orders.properties

我收到以下错误:

Error: the Kafka Connect API returned: Connector cassandra-sink-orders already exists (409) 

如何删除现有的连接器?

我创建了一个cassandra-sink连接器,之后我对connector.properties文件进行了一些更改。在停止工作程序并重新启动它之后,现在当我使用以下命令添加连接器时:java -jar kafka -...

apache-kafka apache-kafka-connect
2个回答
4
投票

您可以使用Kafka Connect REST API,其中包括用于DELETE连接器的端点。


13
投票

要删除连接器,可以运行:

© www.soinside.com 2019 - 2024. All rights reserved.