有 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 资源与配置一起使用,这将启动连接器。
我有一个从 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 资源与配置一起使用,这将启动连接器。