Modifier and Type | Method and Description |
---|---|
MongoConfiguration |
MongoConfiguration.withCollection(String collection) |
MongoConfiguration |
MongoConfiguration.withDb(String db) |
MongoConfiguration |
MongoConfiguration.withHost(String host) |
MongoConfiguration |
MongoConfiguration.withPassword(String password) |
MongoConfiguration |
MongoConfiguration.withPort(Long port) |
MongoConfiguration |
MongoConfiguration.withUser(String user) |
Constructor and Description |
---|
MongoPersistReader(MongoConfiguration config)
KafkaPersistReader constructor - uses supplied MongoConfiguration.
|
MongoPersistWriter(MongoConfiguration config) |
Copyright © 2018 The Apache Software Foundation. All rights reserved.