Code Review / dcaegen2 / services.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: b14c576) | patch
supports multiple Kafka clusters and DBs 92/90692/1
authorGuobiao Mo <guobiaomo@chinamobile.com>
Fri, 28 Jun 2019 21:51:10 +0000 (14:51 -0700)
committerGuobiao Mo <guobiaomo@chinamobile.com>
Fri, 28 Jun 2019 21:51:10 +0000 (14:51 -0700)
commitaaab75304e99b08b3771fabfac08d61d27721ea5
treede6e3b7b3ac2f595fa49171f232c15e05b627b8ftree | snapshot
parentb14c5766902d486a94a8db96d2a31ff0e9e8255ecommit | diff
supports multiple Kafka clusters and DBs

Read data from Kafka and store into DBs

Issue-ID: DCAEGEN2-1631

Change-Id: Ib8fccfd84cfdcd2e284ba4f2503b0fbfe41eb5ae
Signed-off-by: Guobiao Mo <guobiaomo@chinamobile.com>
14 files changed:
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/config/ApplicationConfiguration.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Db.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Kafka.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DbService.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DmaapService.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/PullService.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/Puller.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/StoreService.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/TopicConfigPollingService.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/TopicService.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/CouchbaseService.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/ElasticsearchService.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/HdfsService.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/MongodbService.java diff | blob | history