Code Review / dcaegen2 / services.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 773360d) | patch
kafka 72/90872/1
authorZhangZihao <zhangzihao@chinamobile.com>
Thu, 4 Jul 2019 02:33:32 +0000 (10:33 +0800)
committerZhangZihao <zhangzihao@chinamobile.com>
Thu, 4 Jul 2019 02:33:44 +0000 (10:33 +0800)
commit027c75f93a010cd115fe5fa882646d6f258b566b
tree494f62100b15c146dae15080c34b245f55fb8a3dtree | snapshot
parent773360d05595c3d1f8c5d55200f06b0e42e7dc3ccommit | diff
kafka

Change-Id: I3084858f2ddc06c42e062f65d65b4d3dec620fd7
Issue-ID: DCAEGEN2-1631
Signed-off-by: ZhangZihao <zhangzihao@chinamobile.com>
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/KafkaController.java [new file with mode: 0644] blob
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 [new file with mode: 0644] blob
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/service/KafkaService.java [new file with mode: 0644] blob
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/TopicService.java diff | blob | history