5

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.

2 Answers 2

5

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 Capture

In case it can help anyone else, you can find it here: castorm/kafka-connect-http

Sign up to request clarification or add additional context in comments.

Comments

1

You can always build your own connectors, to stream from http source in a set of intervals is relatively simple.

I am aware that you may have solved your problems, a naive implementation can be found: https://github.com/pegerto/kafka-connect-http

Regards.

Comments

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge you have read our privacy policy.

Start asking to get answers

Find the answer to your question by asking.

Ask question

Explore related questions

See similar questions with these tags.