我在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 -...