Changes to support Kafka over SSL in APEX 60/121160/1
authora.sreekumar <ajith.sreekumar@bell.ca>
Wed, 21 Apr 2021 14:01:30 +0000 (15:01 +0100)
committerAjith Sreekumar <ajith.sreekumar@bell.ca>
Fri, 7 May 2021 10:59:26 +0000 (10:59 +0000)
commit65a74af54d786c9217e4a8993e025e1748892bd8
tree1540da655ce58ee5b7d6bb3e1266ba63bca78a31
parentaf41a79aa9554919b83b5120f18e1f130ecb59b4
Changes to support Kafka over SSL in APEX

The Kafka plugin in APEX-PDP already has a field "kafkaProperties" that
can take in any properties required for the Kafka client. This is apt to
store the SSL related properties as they could change based on the
server implementation.

To make the communication possible, the only change required in APEX is
to allow a property to have an empty value.
For e.g., to disable the server host name verification, ssl.endpoint.identification.algorithm must to be explicitly set to an empty string on the client.

Change-Id: If3adaeaf11e5fbbd2aff582b5d4ba7824017ea8a
Issue-ID: POLICY-3194
Signed-off-by: a.sreekumar <ajith.sreekumar@bell.ca>
(cherry picked from commit bd21c78ed6953de4e8f9fd43311fd22bee7a5472)
plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/main/java/org/onap/policy/apex/plugins/event/carrier/kafka/KafkaCarrierTechnologyParameters.java
plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/KafkaCarrierTechnologyParametersTest.java