Code Review / dcaegen2 / services.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 7a09486) | patch
supports multiple Kafka clusters and DBs 35/91135/1
authorGuobiao Mo <guobiaomo@chinamobile.com>
Wed, 10 Jul 2019 08:34:20 +0000 (01:34 -0700)
committerGuobiao Mo <guobiaomo@chinamobile.com>
Wed, 10 Jul 2019 08:34:20 +0000 (01:34 -0700)
commite5c87e6ddfc5e727b1b4d11e994ad242fd366534
tree5802f76f19549f08a7513e7e2673cfdd3177ce81tree | snapshot
parent7a094862a6a679b022bf777d3f15e32a048ba4d8commit | diff
supports multiple Kafka clusters and DBs

Change kafka table id to int

Issue-ID: DCAEGEN2-1631

Change-Id: Ib5109b75a387f76709dc38161bf2d7ef084950ef
Signed-off-by: Guobiao Mo <guobiaomo@chinamobile.com>
21 files changed:
components/datalake-handler/feeder/src/assembly/scripts/init_db.sql diff | blob | history
components/datalake-handler/feeder/src/assembly/scripts/init_db_data.sql diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/KafkaController.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/TopicController.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/domain/Topic.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/dto/KafkaConfig.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/dto/TopicConfig.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/enumeration/DbTypeEnum.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/repository/KafkaRepository.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/KafkaService.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/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/MongodbService.java diff | blob | history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/TopicConfigPollingServiceTest.java diff | blob | history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/TopicServiceTest.java diff | blob | history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/util/TestUtil.java diff | blob | history