2

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

有相同的命令。我想知道如何在 Python 脚本中做到这一点。提前致谢！

4

1 回答 1

1

如果您使用 Connect 的分布式模式，您可以使用请求之类的库来进行REST API调用。您只需使用配置POST访问连接器资源即可启动连接器。

于 2016-11-03T23:42:37.477 回答