| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253 |
- # 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=localhost: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=
- ############################# 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=
|
