Skip to content

guolsnetgap/kafka_connector

 
 

Repository files navigation

MindsDB Kafka Sink Connector

Basic example of a Kafka Connect sink connector. This is a WIP. The current implementation sends config data to a mindsdb server, in order to start a consumer in the server pointing to a kafka data stream. The tasks of this connector only print data to console.

Requirements

  • jdk 11
  • maven
  • docker-compose

Building the project locally

With maven installed in your system, simply run:

$ mvn clean package

Running the project

To start a local kafka server with the connector included, simply run

$ docker-compose up -d

The compose file builds the project's Dockerfile, which takes care of building the project and adding it to kafka connect. Once all the containers are running, you can manually add the connector in localhost:9021.

About

No description, website, or topics provided.

Resources

License

Stars

Watchers

Forks

Packages

 
 
 

Contributors

Languages

  • Java 84.1%
  • Python 15.2%
  • Dockerfile 0.7%