source-kafka-connect
v1.0.1
Published
connect the kafka and mongodb internal
Downloads
12
Readme
Kafka mongo Source connector
use the mongodb action with the given topic emition
Installation
Use the package manager npm to install connector.
npm i source-kafka-connect
Usage
const connectorSource = require('../kafka/connector')
const secretKey = 'YXKCKB1UJPHWVFM71DNRTEDB75KBYPD2';
const mongoUrl = 'mongodb+srv://<userName>:<password>@cluster0.hjkkd4x.mongodb.net';
const dbName = <DBNAME>;
const collectionName = <COLLECTIONNAME>;
const sourceConnectorName = <userdefined connection name>
const connector = new connectorSource(secretKey , sourceConnectorName , mongoUrl , dbName , collectionName)
connector.startConnector()
Contributing
Pull requests are welcome. For major changes, please open an issue first to discuss what you would like to change.
Please make sure to update tests as appropriate.