1
我有一個從Kafka主題讀取的應用程序。現在，我需要使用Kafka連接器將這些文件發送到HDFS： http://docs.confluent.io/2.0.0/connect/connect-hdfs/docs/index.html是否有Kafka Connect Python客戶端？
有相同的命令。我想知道如何在Python腳本中完成這項工作。提前致謝！
A
回答
1
如果您使用Connect的distributed mode，則可以使用類似requests的庫來撥打REST API調用。你只需POST到connectors資源與配置，並將啓動連接器。
相關問題
- 1. 是否有Python ebXML客戶端？
- 2. 在kafka-python客戶端使用消息
- 3. 連接到Apache Zookeeper的Apache Kafka客戶端客戶端：EndOfStreamException
- 4. Kafka Connect的用例
- 5. 將JMS客戶端連接到Apache Kafka
- 6. 將kafka客戶端從0.8.0升級到0.10.0.1時是否會有數據丟失？
- 7. Kafka Connect + Zookepeer沒有連接
- 8. 是否有客戶端JavaScript mimetype庫？
- 9. 是否有Erlang BERT-RPC客戶端？
- 10. Oauth2是否有任何Php客戶端？
- 11. 是否有Expression Blend的SVN客戶端？
- 12. Mondrian是否有本地客戶端？
- 13. 是否有PouchDB的GUI客戶端？
- 14. 是否有適用於DC/OS，ElasticSearch，Kafka Connect和Kafka Streams的CloudFormation模板？
- 15. 帶選擇器的Apache Kafka客戶端？
- 16. 爲Kafka客戶端啓用SSL
- 17. Python中是否有任何Bayeux客戶端？
- 18. 是否有支持異步請求的Python ElasticSearch客戶端？
- 19. 是否有爲python實現的WebSocket客戶端？
- 20. Python是否有豐富的ftp客戶端庫？
- 21. Confluent Kafka：如何在confluent-kafka-python客戶端中指定序列化和分區？
- 22. Google Friend Connect OpenSocial PHP客戶端
- 23. 帶客戶端的Android客戶端Python
- 24. Kafka Connect Logstash
- 25. Kafka Connect MySQL
- 26. Kafka Connect集成
- 27. 如何在gevent中使用python kafka客戶端 - 是否有實際工作的庫文件？
- 28. HTTPS Python客戶端
- 29. Python fastcgi客戶端
- 30. 是否有可能使客戶端與HTML5的客戶端連接
嗨Ewen！感謝我們的迴應。我試過這個： localhost是我的引導服務器和zookeeper （分別爲9092和2181個端口）。但我得到連接錯誤。 'File「/usr/lib/python2.6/site-packages/requests/adapters.py」，第413行，發送 raise ConnectionError（err，request = request） requests.exceptions.ConnectionError :('連接中止'，錯誤（111，'拒絕連接'））' – NoName
您可能沒有在正確的端口上發出請求。由於您剛剛使用'http：// localhost/connector'，因此您正在對端口80發出請求。默認情況下，REST API會在8083上偵聽，因此您可能需要'http：// localhost：8083/connectors' –
Hello Ewen，感謝您的解決方案。我嘗試過，但運行'bin/connect-distributed.sh config/connect-distributed.properties'時出現以下錯誤： 'ERROR牧民工作線程中未捕獲的異常，退出：（org.apache.kafka.connect。 runtime.distributed.DistributedHerder：183） org.apache.kafka.common.errors.TimeoutException：超時時提取主題元數據' 而我的腳本返回'' –
NoName