Code Review / policy / common.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 15ede09) | patch
Introduce Custom Kafka End point 38/129838/3
authorSirisha_Manchikanti <sirisha.manchikanti@est.tech>
Fri, 1 Jul 2022 06:15:00 +0000 (07:15 +0100)
committerSirisha_Manchikanti <sirisha.manchikanti@est.tech>
Fri, 22 Jul 2022 19:17:46 +0000 (20:17 +0100)
commit2a2b5d085876480c1b0d9470a57c6cab4f51008c
tree64bd2ded017ad43bd995686e2e7b8f1ffa412a40tree | snapshot
parent15ede09d6ef4b52db05fab534eed7192991b1f98commit | diff
Introduce Custom Kafka End point

Issue-ID: POLICY-4133
Signed-off-by: Sirisha_Manchikanti <sirisha.manchikanti@est.tech>
Change-Id: I2745f3af97e9bb83d94c5cb6d29dfd452d315506
26 files changed:
policy-endpoints/pom.xml diff | blob | history
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/Topic.java diff | blob | history
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpoint.java diff | blob | history
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java diff | blob | history
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/IndexedKafkaTopicSinkFactory.java [new file with mode: 0644] blob
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/IndexedKafkaTopicSourceFactory.java [new file with mode: 0644] blob
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/KafkaTopicFactories.java [new file with mode: 0644] blob
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/KafkaTopicSink.java [new file with mode: 0644] blob
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/KafkaTopicSinkFactory.java [new file with mode: 0644] blob
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/KafkaTopicSource.java [new file with mode: 0644] blob
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/KafkaTopicSourceFactory.java [new file with mode: 0644] blob
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/BusConsumer.java diff | blob | history
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/BusPublisher.java diff | blob | history
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/InlineKafkaTopicSink.java [new file with mode: 0644] blob
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedKafkaTopicSource.java [new file with mode: 0644] blob
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/properties/PolicyEndPointProperties.java diff | blob | history
policy-endpoints/src/main/java/org/onap/policy/common/endpoints/utils/KafkaPropertyUtils.java [new file with mode: 0644] blob
policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/KafkaTopicFactoryTestBase.java [new file with mode: 0644] blob
policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/KafkaTopicPropertyBuilder.java [new file with mode: 0644] blob
policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/KafkaTopicSinkTest.java [new file with mode: 0644] blob
policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/KafkaTopicSourceFactoryTest.java [new file with mode: 0644] blob
policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/KafkaTopicSourceTest.java [new file with mode: 0644] blob
policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/internal/BusConsumerTest.java diff | blob | history
policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedKafkaTopicSourceTest.java [new file with mode: 0644] blob
policy-endpoints/src/test/resources/org/onap/policy/common/endpoints/event/comm/bus/internal/InlineKafkaTopicSinkTest.json [new file with mode: 0644] blob
policy-endpoints/src/test/resources/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedKafkaTopicSourceTest.json [new file with mode: 0644] blob
Policy common shared modules