changes for kafka upgrade
[dmaap/messagerouter/mirroragent.git] / src / main / config / consumer.properties
1 # Licensed to the Apache Software Foundation (ASF) under one or more
2 # contributor license agreements.  See the NOTICE file distributed with
3 # this work for additional information regarding copyright ownership.
4 # The ASF licenses this file to You under the Apache License, Version 2.0
5 # (the "License"); you may not use this file except in compliance with
6 # the License.  You may obtain a copy of the License at
7 #
8 #    http://www.apache.org/licenses/LICENSE-2.0
9 #
10 # Unless required by applicable law or agreed to in writing, software
11 # distributed under the License is distributed on an "AS IS" BASIS,
12 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 # See the License for the specific language governing permissions and
14 # limitations under the License.
15 # see kafka.consumer.ConsumerConfig for more details
16
17 # Zookeeper connection string
18 # comma separated host:port pairs, each corresponding to a zk
19 # server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002"
20 #zookeeper.connect=127.0.0.1:2181
21
22 # timeout in ms for connecting to zookeeper
23 #zookeeper.connection.timeout.ms=6000
24
25 #consumer group id
26 group.id=test-consumer-group
27
28 #New MirrorMaker properties for Kafka 0.11 version
29 #Kafka 0.11 uses Kafka to manage consumers instead of ZK.
30 bootstrap.servers=127.0.0.1:9092
31 client.id=mirror_maker_consumer
32
33 #Following properties are required as MR 1.2 will use Kafka 0.11 with AAF Auth wrapper.
34 security.protocol=SASL_PLAINTEXT
35 sasl.mechanism=PLAIN
36 #java.security.auth.login.config=/opt/app/dmaap/mmagent/etc/kafka_client_jaas.conf
37 sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="admin_secret";
38
39
40 #consumer timeout:
41 #consumer.timeout.ms=5000