1 ###############################################################################
2 # ============LICENSE_START=======================================================
4 # ================================================================================
5 # Copyright © 2017 AT&T Intellectual Property. All rights reserved.
6 # ================================================================================
7 # Licensed under the Apache License, Version 2.0 (the "License");
8 # you may not use this file except in compliance with the License.
9 # You may obtain a copy of the License at
10 # http://www.apache.org/licenses/LICENSE-2.0
12 # Unless required by applicable law or agreed to in writing, software
13 # distributed under the License is distributed on an "AS IS" BASIS,
14 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 # See the License for the specific language governing permissions and
16 # limitations under the License.
17 # ============LICENSE_END=========================================================
19 # ECOMP is a trademark and service mark of AT&T Intellectual Property.
21 ###############################################################################
22 # Licensed to the Apache Software Foundation (ASF) under one or more
23 # contributor license agreements. See the NOTICE file distributed with
24 # this work for additional information regarding copyright ownership.
25 # The ASF licenses this file to You under the Apache License, Version 2.0
26 # (the "License"); you may not use this file except in compliance with
27 # the License. You may obtain a copy of the License at
29 # http://www.apache.org/licenses/LICENSE-2.0
31 # Unless required by applicable law or agreed to in writing, software
32 # distributed under the License is distributed on an "AS IS" BASIS,
33 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
34 # See the License for the specific language governing permissions and
35 # limitations under the License.
36 # see kafka.producer.ProducerConfig for more details
38 ############################# Producer Basics #############################
40 # list of brokers used for bootstrapping knowledge about the rest of the cluster
41 # format: host1:port1,host2:port2 ...
42 metadata.broker.list=104.130.132.211:9092
44 # name of the partitioner class for partitioning events; default partition spreads data randomly
47 # specifies whether the messages are sent asynchronously (async) or synchronously (sync)
50 # specify the compression codec for all data generated: none, gzip, snappy, lz4.
51 # the old config values work as well: 0, 1, 2, 3 for none, gzip, snappy, lz4, respectively
52 compression.codec=none
55 serializer.class=kafka.serializer.DefaultEncoder
57 # allow topic level compression
60 ############################# Async Producer #############################
61 # maximum time, in milliseconds, for buffering data on the producer queue
62 #queue.buffering.max.ms=
64 # the maximum size of the blocking queue for buffering on the producer
65 #queue.buffering.max.messages=
67 # Timeout for event enqueue:
68 # 0: events will be enqueued immediately or dropped if the queue is full
69 # -ve: enqueue will block indefinitely if the queue is full
70 # +ve: enqueue will block up to this many milliseconds if the queue is full
71 #queue.enqueue.timeout.ms=
73 # the number of messages batched at the producer