From 1ee517bedb7c1634e37c1124676f001b95840985 Mon Sep 17 00:00:00 2001 From: sunil unnava Date: Wed, 20 Jun 2018 17:08:42 -0400 Subject: changes for kafka upgrade Issue-ID: DMAAP-513 Change-Id: I614ff2919e28c3194eab6bb731d076d9c91be1d7 Signed-off-by: sunil unnava --- src/main/config/consumer.properties | 43 +++++++++++++++---------------------- 1 file changed, 17 insertions(+), 26 deletions(-) (limited to 'src/main/config/consumer.properties') diff --git a/src/main/config/consumer.properties b/src/main/config/consumer.properties index 08d29af..5ec6df2 100644 --- a/src/main/config/consumer.properties +++ b/src/main/config/consumer.properties @@ -1,33 +1,12 @@ -############################################################################### -# ============LICENSE_START======================================================= -# org.onap.dmaap -# ================================================================================ -# Copyright © 2017 AT&T Intellectual Property. All rights reserved. -# ================================================================================ -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. -# ============LICENSE_END========================================================= -# -# ECOMP is a trademark and service mark of AT&T Intellectual Property. -# -############################################################################### # Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE file distributed with # this work for additional information regarding copyright ownership. # The ASF licenses this file to You under the Apache License, Version 2.0 # (the "License"); you may not use this file except in compliance with # the License. You may obtain a copy of the License at -# +# # http://www.apache.org/licenses/LICENSE-2.0 -# +# # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -38,13 +17,25 @@ # Zookeeper connection string # comma separated host:port pairs, each corresponding to a zk # server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002" -zookeeper.connect=172.18.0.1:2181 +#zookeeper.connect=127.0.0.1:2181 # timeout in ms for connecting to zookeeper -zookeeper.connection.timeout.ms=6000 +#zookeeper.connection.timeout.ms=6000 #consumer group id group.id=test-consumer-group -#consumer timeout +#New MirrorMaker properties for Kafka 0.11 version +#Kafka 0.11 uses Kafka to manage consumers instead of ZK. +bootstrap.servers=127.0.0.1:9092 +client.id=mirror_maker_consumer + +#Following properties are required as MR 1.2 will use Kafka 0.11 with AAF Auth wrapper. +security.protocol=SASL_PLAINTEXT +sasl.mechanism=PLAIN +#java.security.auth.login.config=/opt/app/dmaap/mmagent/etc/kafka_client_jaas.conf +sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="admin_secret"; + + +#consumer timeout: #consumer.timeout.ms=5000 -- cgit 1.2.3-korg