Code Review / nonrtric / plt / ranpm.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: ebd1c0b) | patch
Added support for using oauth token for Kafka 53/10753/8
authorPatrikBuhr <patrik.buhr@est.tech>
Tue, 21 Mar 2023 09:16:11 +0000 (10:16 +0100)
committerPatrikBuhr <patrik.buhr@est.tech>
Thu, 23 Mar 2023 08:41:54 +0000 (09:41 +0100)
commit298969556b0f84de745a67e994a590d8b2a3de13
tree40e7a501d37224ed05cd40a4060becdf5b8e00fatree | snapshot
parentebd1c0b01fb80f1313678c777d4b1cb46800c23dcommit | diff
Added support for using oauth token for Kafka

in pmproducer and in influxlogger

OAUTHBEARER is supported as SASL mechanism.
This can be done over SSL or plain text.

Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-853
Change-Id: I96afd34457da1a7115d417e7a11cc3072d284e00
30 files changed:
influxlogger/config/application.yaml diff | blob | history
influxlogger/src/main/java/org/oran/pmlog/ConsumerRegstrationTask.java diff | blob | history
influxlogger/src/main/java/org/oran/pmlog/KafkaTopicListener.java diff | blob | history
influxlogger/src/main/java/org/oran/pmlog/clients/AsyncRestClient.java diff | blob | history
influxlogger/src/main/java/org/oran/pmlog/clients/AsyncRestClientFactory.java diff | blob | history
influxlogger/src/main/java/org/oran/pmlog/configuration/ApplicationConfig.java diff | blob | history
influxlogger/src/main/java/org/oran/pmlog/exceptions/ServiceException.java diff | blob | history
influxlogger/src/main/java/org/oran/pmlog/oauth2/OAuthBearerTokenJwt.java [new file with mode: 0644] blob
influxlogger/src/main/java/org/oran/pmlog/oauth2/OAuthKafkaAuthenticateLoginCallbackHandler.java [new file with mode: 0644] blob
influxlogger/src/main/java/org/oran/pmlog/oauth2/SecurityContext.java [moved from pmproducer/src/main/java/org/oran/pmproducer/clients/SecurityContext.java with 90% similarity] diff | blob | history
influxlogger/src/test/java/org/oran/pmlog/ApplicationTest.java diff | blob | history
influxlogger/src/test/java/org/oran/pmlog/Integration.java diff | blob | history
influxlogger/src/test/resources/jwtToken.b64 [new file with mode: 0644] blob
pmproducer/config/application.yaml diff | blob | history
pmproducer/src/main/java/org/oran/pmproducer/Application.java diff | blob | history
pmproducer/src/main/java/org/oran/pmproducer/clients/AsyncRestClient.java diff | blob | history
pmproducer/src/main/java/org/oran/pmproducer/clients/AsyncRestClientFactory.java diff | blob | history
pmproducer/src/main/java/org/oran/pmproducer/configuration/ApplicationConfig.java diff | blob | history
pmproducer/src/main/java/org/oran/pmproducer/exceptions/ServiceException.java diff | blob | history
pmproducer/src/main/java/org/oran/pmproducer/oauth2/OAuthBearerTokenJwt.java [new file with mode: 0644] blob
pmproducer/src/main/java/org/oran/pmproducer/oauth2/OAuthKafkaAuthenticateLoginCallbackHandler.java [new file with mode: 0644] blob
pmproducer/src/main/java/org/oran/pmproducer/oauth2/SecurityContext.java [moved from influxlogger/src/main/java/org/oran/pmlog/clients/SecurityContext.java with 85% similarity] diff | blob | history
pmproducer/src/main/java/org/oran/pmproducer/repository/Jobs.java diff | blob | history
pmproducer/src/main/java/org/oran/pmproducer/tasks/JobDataDistributor.java diff | blob | history
pmproducer/src/main/java/org/oran/pmproducer/tasks/ProducerRegstrationTask.java diff | blob | history
pmproducer/src/main/java/org/oran/pmproducer/tasks/TopicListener.java diff | blob | history
pmproducer/src/test/java/org/oran/pmproducer/ApplicationTest.java diff | blob | history
pmproducer/src/test/java/org/oran/pmproducer/IntegrationWithIcs.java diff | blob | history
pmproducer/src/test/java/org/oran/pmproducer/IntegrationWithKafka.java diff | blob | history
pmproducer/src/test/resources/jwtToken.b64 [new file with mode: 0644] blob
"nonrtric_plt_ranpm"