kafka 连接器 HTTP/API 源

如果它可以帮助其他人，你可以在这里找到它:castorm/kafka-connect-httpI am actually aware on how to capture data from any data source, such as a specific API (e.g HTTP GET request) and ingest them in specific kafka connector. { "name": "localfileSource", "config": { "connector.class": "FileStreamSourceConnector", "tasks.max": "1", "file": "test.txt", "topic": "connectSource" }}I would need something similar to this(FileStreamSourceConnector), that can be used with API sources. 解决方案 It's probably a bit late for the question asker, but I had a similar need and I decided to implement my own connector.The particularity of the connector is that it implements some sort of Change Data CaptureIn case it can help anyone else, you can find it here: castorm/kafka-connect-http 这篇关于kafka 连接器 HTTP/API 源的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！