MongoDB Kafka Connector
The official MongoDB Kafka Connector.
Documentation for the connector is available on https://docs.mongodb.com/kafka-connector/current/
The connector will be published on maven central.
For issues with, questions about, or feedback for the MongoDB Kafka Connector, please look into our support channels. Please do not email any of the Kafka connector developers directly with issues or questions - you're more likely to get an answer on the MongoDB Community Forums.
At a minimum, please include in your description the exact version of the driver that you are using. If you are having connectivity issues, it's often also useful to paste in the Kafka connector configuration. You should also check your application logs for any connectivity-related exceptions and post those as well.
Think you’ve found a bug? Want to see a new feature in the Kafka driver? Please open a case in our issue management tool, JIRA:
Bug reports in JIRA for the connector are public.
If you’ve identified a security vulnerability in a connector or any other MongoDB project, please report it according to the instructions here.
The MongoDB Kafka Connector follows semantic versioning. See the changelog for information about changes between releases.
Java 8+ is required to build and compile the source. To build and test the driver:
$ git clone https://github.com/mongodb/mongo-kafka.git $ cd mongo-kafka $ ./gradlew check -Dorg.mongodb.test.uri=mongodb://localhost:27017
The test suite requires mongod to be running. Note, the source connector requires a replicaSet.
Original Sink connector work by: Hans-Peter Grahsl : https://github.com/hpgrahsl/kafka-connect-mongodb
Additional contributors can be found here.
./gradlew publishArchives- publishes to Maven
./gradlew createConfluentArchive- creates the confluent archive / github release zip file
A couple of manual configuration steps are required to run the code in IntelliJ:
java: cannot find symbol. symbol: variable Versions
./gradlew compileBuildConfigor via Gradle > mongo-kafka > Tasks > other > compileBuildConfig
compileBuildConfigto execute Before Build. via Gradle > Tasks > other > right click compileBuildConfig - click on "Execute Before Build"