有 Kafka Connect Python 客户端吗?

Is there a Kafka Connect Python Client?

我有一个从 Kafka 主题读取的应用程序。现在,我需要使用 Kafka 连接器将这些发送到 HDFS: http://docs.confluent.io/2.0.0/connect/connect-hdfs/docs/index.html

有相同的命令。我想知道如何在 Python 脚本中完成此操作。提前致谢!

如果您将 distributed mode of Connect, you can use a library like requests to make REST API calls. You would just POST to the connectors 资源与配置一起使用,这将启动连接器。