diff options
Diffstat (limited to 'src/main/docker/producer.properties')
-rw-r--r-- | src/main/docker/producer.properties | 70 |
1 files changed, 0 insertions, 70 deletions
diff --git a/src/main/docker/producer.properties b/src/main/docker/producer.properties deleted file mode 100644 index 78ff7c7..0000000 --- a/src/main/docker/producer.properties +++ /dev/null @@ -1,70 +0,0 @@ -# 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.producer.ProducerConfig for more details - -############################# Producer Basics ############################# - -# list of brokers used for bootstrapping knowledge about the rest of the cluster -# format: host1:port1,host2:port2 ... -#metadata.broker.list=172.16.96.14:9092 - -# name of the partitioner class for partitioning events; default partition spreads data randomly -#partitioner.class= - -# specifies whether the messages are sent asynchronously (async) or synchronously (sync) -producer.type=sync - -# specify the compression codec for all data generated: none, gzip, snappy, lz4. -# the old config values work as well: 0, 1, 2, 3 for none, gzip, snappy, lz4, respectively -#compression.codec=none - -# message encoder -#serializer.class=kafka.serializer.DefaultEncoder - -# allow topic level compression -#compressed.topics= - -#New MirrorMaker properties for Kafka 0.11 version -#list of brokers used for bootstrapping knowledge about the rest of the cluster -# format: host1:port1,host2:port2 ... -bootstrap.servers=172.16.96.14:9092 - -#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"; - -#Producer -compression.type=none -#serializer.class=kafka.serializer.DefaultEncoder -batch.size=100 -client.id=mirror_maker_producer - -############################# Async Producer ############################# -# maximum time, in milliseconds, for buffering data on the producer queue -#queue.buffering.max.ms= - -# the maximum size of the blocking queue for buffering on the producer -#queue.buffering.max.messages= - -# Timeout for event enqueue: -# 0: events will be enqueued immediately or dropped if the queue is full -# -ve: enqueue will block indefinitely if the queue is full -# +ve: enqueue will block up to this many milliseconds if the queue is full -#queue.enqueue.timeout.ms= - -# the number of messages batched at the producer -#batch.num.messages= |