I 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.