src/main/config/producer.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.producer.ProducerConfig for more details
  16
  17 ############################# Producer Basics #############################
  18
  19 # list of brokers used for bootstrapping knowledge about the rest of the cluster
  20 # format: host1:port1,host2:port2 ...
  21 #metadata.broker.list=172.16.96.14:9092
  22
  23 # name of the partitioner class for partitioning events; default partition spreads data randomly
  24 #partitioner.class=
  25
  26 # specifies whether the messages are sent asynchronously (async) or synchronously (sync)
  27 producer.type=sync
  28
  29 # specify the compression codec for all data generated: none, gzip, snappy, lz4.
  30 # the old config values work as well: 0, 1, 2, 3 for none, gzip, snappy, lz4, respectively
  31 #compression.codec=none
  32
  33 # message encoder
  34 #serializer.class=kafka.serializer.DefaultEncoder
  35
  36 # allow topic level compression
  37 #compressed.topics=
  38
  39 #New MirrorMaker properties for Kafka 0.11 version
  40 #list of brokers used for bootstrapping knowledge about the rest of the cluster
  41 # format: host1:port1,host2:port2 ...
  42 bootstrap.servers=172.16.96.14:9092
  43
  44 #Following properties are required as MR 1.2 will use Kafka 0.11 with AAF Auth wrapper.
  45 security.protocol=SASL_PLAINTEXT
  46 sasl.mechanism=PLAIN
  47 #java.security.auth.login.config=/opt/app/dmaap/mmagent/etc/kafka_client_jaas.conf
  48 sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="admin_secret";
  49
  50 #Producer
  51 compression.type=none
  52 #serializer.class=kafka.serializer.DefaultEncoder
  53 batch.size=100
  54 client.id=mirror_maker_producer
  55
  56 ############################# Async Producer #############################
  57 # maximum time, in milliseconds, for buffering data on the producer queue
  58 #queue.buffering.max.ms=
  59
  60 # the maximum size of the blocking queue for buffering on the producer
  61 #queue.buffering.max.messages=
  62
  63 # Timeout for event enqueue:
  64 # 0: events will be enqueued immediately or dropped if the queue is full
  65 # -ve: enqueue will block indefinitely if the queue is full
  66 # +ve: enqueue will block up to this many milliseconds if the queue is full
  67 #queue.enqueue.timeout.ms=
  68
  69 # the number of messages batched at the producer
  70 #batch.num.messages=