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 Connect的用例
- 3. 將JMS客戶端連接到Apache Kafka
- 4. 將kafka客戶端從0.8.0升級到0.10.0.1時是否會有數據丟失？
- 5. Kafka Connect + Zookepeer沒有連接
- 6. 是否有Expression Blend的SVN客戶端？
- 7. Python中是否有任何Bayeux客戶端？
- 8. 是否有爲python實現的WebSocket客戶端？
- 9. Google Friend Connect OpenSocial PHP客戶端
- 10. 帶選擇器的Apache Kafka客戶端？
- 11. 爲Kafka客戶端啓用SSL
- 12. Confluent Kafka：如何在confluent-kafka-python客戶端中指定序列化和分區？
- 13. Kafka Connect Logstash
- 14. Kafka Connect MySQL
- 15. Kafka Connect集成
- 16. 是否有可能使客戶端與HTML5的客戶端連接
- 17. 是否有可能爲Android創建一個「客戶端到客戶端」系統？
- 18. GPSD Python客戶端
- 19. 什麼是合適的Apache Kafka客戶端罐子
- 20. 氣流python客戶端
- 21. 是否有可能有客戶端驗證沒有JavaScript
- 22. FreeOPCUA python客戶端示例
- 23. RESTeasy客戶端是否支持TLS/SSL？
- 24. 「will_paginate」是否支持客戶端分頁？
- 25. Weblogic.Messaging.dll .NET客戶端是否支持T3S？
- 26. 是否依賴System.DateTime客戶端？
- 27. angularjs是否工作在客戶端？
- 28. 是否支持ssh客戶端配置
- 29. JAX-WS客戶端是否安全？
- 30. JAX-WS客戶端：JAXB是否需要？
嗨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