# 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. # See the License for the specific language governing permissions and # limitations under the License. # see kafka.consumer.ConsumerConfig for more details # 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=127.0.0.1:2181 # timeout in ms for connecting to zookeeper #zookeeper.connection.timeout.ms=6000 #consumer group id group.id=test-consumer-group #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