RADAR-base/RADAR-MongoDB-Sink-Connector

Name: RADAR-MongoDB-Sink-Connector

Owner: RADAR-CNS

Owner: RADAR-CNS

Description: MongoDbConnector for RADAR-CNS platform

Created: 2017-03-01 16:08:07.0

Updated: 2017-06-21 10:28:59.0

Pushed: 2017-11-30 16:31:46.0

Homepage:

Size: 10479

Language: Java

GitHub Committers

User	Most Recent Commit	# Commits

Other Committers

User	Email	Most Recent Commit	# Commits

README

RADAR-MongoDB-Sink-Connector

Implements the hot-storage support for RADAR-CNS platform using MongoDBSinkConnector

To Run Radar-MongoDB-Connector

1. In addition to Zookeeper, Kafka-broker(s), Schema-registry and Rest-proxy, MongoDB should be running with required credentials

2. Load the radar-mongodb-sink-connector-*.jar to CLASSPATH

   rt CLASSPATH=/path/to/radar-mongodb-sink-connector-0.1.jar
   

3. Configure MongoDB Connector properties.

   fka consumer configuration
   =radar-connector-mongodb-sink
   
   fka connector configuration
   ector.class=org.radarcns.mongodb.MongoDbSinkConnector
   s.max=1
   
   pics that will be consumed
   cs=topics
   
   ngoDB server
   o.host=localhost
   o.port=27017
   
   ngoDB configuration
   o.username=
   o.password=
   o.database=
   
   llection name for putting data into the MongoDB database. The {$topic} token will be replaced
    the Kafka topic name.
   go.collection.format={$topic}
   
   ctory class to do the actual record conversion
   rd.converter.class=org.radarcns.sink.mongodb.RecordConverterFactoryRadar
   

   For more details visit our MongoDBConnector and Kafka-Connect

4. Run the connector. To run the connector in standalone mode (on an enviornment where the Confluent platform is installed):

   ect-standalone /etc/schema-registry/connect-avro-standalone.properties path-to-your-mongodb-connector.properties
   

Contributing

New converters

• should implement the interface org.radarcns.serialization.RecordConverte
• should be located under the org.radarcns.sink.mongodb.converter package
• should be listed in org.radarcns.sink.mongodb.RecordConverterFactoryRadar to be added to the class path

The converters should take advantages of org.bson.codecs.Encoder<T>. Instances of this class are capable of encoding an instance of the type parameter T into a BSON value. The counter part is org.bson.codecs.Decoder<T>

Code should be formatted using the Google Java Code Style Guide. If you want to contribute a feature or fix browse our issues, and please make a pull request.