Code Review / nonrtric.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: a380b6f) | patch
New simple kafka consumer microservice 62/13562/2
authorlapentafd <francesco.lapenta@est.tech>
Wed, 25 Sep 2024 09:06:01 +0000 (10:06 +0100)
committerFrancesco Davide Lapenta <francesco.lapenta@est.tech>
Thu, 10 Oct 2024 10:22:13 +0000 (10:22 +0000)
commit51b20fd9d3b27a8ee872bceff30be7cd1066d80e
tree600a2a5d47f4926bec93d74fb8b322bae55b0213tree | snapshot
parenta380b6f85e9b160fadc8ce0b070d65f27ffb26bacommit | diff
New simple kafka consumer microservice

Using Spring kafka listener in a simple reactive way

Issue-ID: NONRTRIC-1009
Change-Id: I5cba8ab6fd83c8c49b3c46403486f5c6b44073c8
Signed-off-by: lapentafd <francesco.lapenta@est.tech>
12 files changed:
sample-services/ics-simple-producer-consumer/kafka-consumer/Dockerfile [new file with mode: 0644] blob
sample-services/ics-simple-producer-consumer/kafka-consumer/container-tag.yaml [new file with mode: 0644] blob
sample-services/ics-simple-producer-consumer/kafka-consumer/pom.xml [new file with mode: 0644] blob
sample-services/ics-simple-producer-consumer/kafka-consumer/src/main/java/com/demo/kafkaconsumer/KafkaConsumerApplication.java [new file with mode: 0644] blob
sample-services/ics-simple-producer-consumer/kafka-consumer/src/main/java/com/demo/kafkaconsumer/configuration/KafkaConfiguration.java [new file with mode: 0644] blob
sample-services/ics-simple-producer-consumer/kafka-consumer/src/main/java/com/demo/kafkaconsumer/controllers/CallbacksController.java [new file with mode: 0644] blob
sample-services/ics-simple-producer-consumer/kafka-consumer/src/main/java/com/demo/kafkaconsumer/controllers/KafkaListenerController.java [new file with mode: 0644] blob
sample-services/ics-simple-producer-consumer/kafka-consumer/src/main/java/com/demo/kafkaconsumer/model/Job.java [new file with mode: 0644] blob
sample-services/ics-simple-producer-consumer/kafka-consumer/src/main/java/com/demo/kafkaconsumer/service/KafkaConsumer.java [new file with mode: 0644] blob
sample-services/ics-simple-producer-consumer/kafka-consumer/src/main/resources/application.yaml [new file with mode: 0644] blob
sample-services/ics-simple-producer-consumer/kafka-consumer/src/test/java/com/demo/kafkaconsumer/KafkaConsumerApplicationTests.java [new file with mode: 0644] blob
sample-services/ics-simple-producer-consumer/kafka-consumer/src/test/java/com/demo/kafkaconsumer/KafkaListenerControllerTest.java [new file with mode: 0644] blob
Parent repository for the O-RAN SC Non Real-Time RIC (NONRTRIC) project.