小编Ale*_*lex的帖子

我实际上知道如何从任何数据源捕获数据，例如特定的 API（例如 HTTP GET 请求）并将它们摄取到特定的 kafka 连接器中。

{
    "name": "localfileSource", 
    "config": {
        "connector.class": "FileStreamSourceConnector",
        "tasks.max": "1",
        "file": "test.txt",
        "topic": "connectSource"
    }
}

我需要类似于 this( FileStreamSourceConnector) 的东西，它可以与 API 源一起使用。