max-file: "5"
kafka:
+ #CADI integrated kafka image
+ #image: nexus3.onap.org:10001/onap/dmaap/kafka01101:0.0.2
image: nexus3.onap.org:10001/onap/dmaap/kafka01101:0.0.1
ports:
- "9092:9092"
environment:
+ enableCadi: false
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
+ #Properties required for using the CADI integrated Kafka
+ #KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INTERNAL_SASL_PLAINTEXT:SASL_PLAINTEXT,EXTERNAL_SASL_PLAINTEXT:SASL_PLAINTEXT
+ #KAFKA_ADVERTISED_LISTENERS: INTERNAL_SASL_PLAINTEXT://kafka:9092
+ #KAFKA_LISTENERS: INTERNAL_SASL_PLAINTEXT://0.0.0.0:9092
+ #KAFKA_INTER_BROKER_LISTENER_NAME: INTERNAL_SASL_PLAINTEXT
+ #KAFKA_SASL_ENABLED_MECHANISMS: PLAIN
+ #KAFKA_SASL_MECHANISM_INTER_BROKER_PROTOCOL: PLAIN
+ #KAFKA_AUTHORIZER_CLASS_NAME: org.onap.dmaap.kafkaAuthorize.KafkaCustomAuthorizer
+ #aaf_locate_url: https://aaf-onap-test.osaaf.org:8095
+ #Remove the below 4 properties if CADI
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INTERNAL_PLAINTEXT:PLAINTEXT,EXTERNAL_PLAINTEXT:PLAINTEXT
KAFKA_ADVERTISED_LISTENERS: INTERNAL_PLAINTEXT://kafka:9092
KAFKA_LISTENERS: INTERNAL_PLAINTEXT://0.0.0.0:9092
max-file: "5"
dmaap:
+ #CADI integrated MR image
+ #image: ${NEXUS_DOCKER_REPO}/onap/dmaap/dmaap-mr:1.1.7
image: ${NEXUS_DOCKER_REPO}/onap/dmaap/dmaap-mr:1.1.6
ports:
- "3904:3904"
<dependency>
<groupId>org.onap.dmaap.messagerouter.msgrtr</groupId>
<artifactId>msgrtr</artifactId>
- <version>1.1.9</version>
+ <version>1.1.10</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
import javax.servlet.ServletResponse;
import javax.servlet.http.HttpServletRequest;
+import com.att.dmf.mr.utils.Utils;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
import org.springframework.stereotype.Component;
log.info("inside servlet filter Cambria Auth Headers checking before doing other Authentication");
HttpServletRequest request = (HttpServletRequest) req;
boolean forceAAF = Boolean.valueOf(System.getProperty("forceAAF"));
+
//if (forceAAF || null != request.getHeader("Authorization") ){
- if (forceAAF || null != request.getHeader("Authorization") ||
+ if (Utils.isCadiEnabled()&&(forceAAF || null != request.getHeader("Authorization") ||
(null != request.getHeader("AppName") && request.getHeader("AppName").equalsIgnoreCase("invenio") &&
- null != request.getHeader("cookie"))){
+ null != request.getHeader("cookie")))){
super.doFilter(req, res, chain);
} else {
- "2181:2181"
kafka:
+ #CADI integrated kafka image
+ #image: nexus3.onap.org:10001/onap/dmaap/kafka01101:0.0.2
image: nexus3.onap.org:10001/onap/dmaap/kafka01101:0.0.1
ports:
- "9092:9092"
environment:
+ enableCadi: false
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
+ #Properties required for using the CADI integrated Kafka
+ #KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INTERNAL_SASL_PLAINTEXT:SASL_PLAINTEXT,EXTERNAL_SASL_PLAINTEXT:SASL_PLAINTEXT
+ #KAFKA_ADVERTISED_LISTENERS: INTERNAL_SASL_PLAINTEXT://kafka:9092
+ #KAFKA_LISTENERS: INTERNAL_SASL_PLAINTEXT://0.0.0.0:9092
+ #KAFKA_INTER_BROKER_LISTENER_NAME: INTERNAL_SASL_PLAINTEXT
+ #KAFKA_SASL_ENABLED_MECHANISMS: PLAIN
+ #KAFKA_SASL_MECHANISM_INTER_BROKER_PROTOCOL: PLAIN
+ #KAFKA_AUTHORIZER_CLASS_NAME: org.onap.dmaap.kafkaAuthorize.KafkaCustomAuthorizer
+ #aaf_locate_url: https://aaf-onap-test.osaaf.org:8095
+ #Remove the below 4 properties if CADI is enabled
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INTERNAL_PLAINTEXT:PLAINTEXT,EXTERNAL_PLAINTEXT:PLAINTEXT
KAFKA_ADVERTISED_LISTENERS: INTERNAL_PLAINTEXT://kafka:9092
KAFKA_LISTENERS: INTERNAL_PLAINTEXT://0.0.0.0:9092
- zookeeper
dmaap:
+ #CADI integrated MR image
+ #image: ${NEXUS_DOCKER_REPO}/onap/dmaap/dmaap-mr:1.1.7
image: nexus3.onap.org:10001/onap/dmaap/dmaap-mr:1.1.6
ports:
- "3904:3904"