Add config files for test cases
[dmaap/messagerouter/mirroragent.git] / src / test / resources / etc / producer.properties
1 ###############################################################################
2 #  ============LICENSE_START=======================================================
3 #  org.onap.dmaap
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
11 #  
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=========================================================
18 #
19 #  ECOMP is a trademark and service mark of AT&T Intellectual Property.
20 #  
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
28 #
29 #    http://www.apache.org/licenses/LICENSE-2.0
30 #
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
37
38 ############################# Producer Basics #############################
39
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
43
44 # name of the partitioner class for partitioning events; default partition spreads data randomly
45 #partitioner.class=
46
47 # specifies whether the messages are sent asynchronously (async) or synchronously (sync)
48 producer.type=sync
49
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
53
54 # message encoder
55 serializer.class=kafka.serializer.DefaultEncoder
56
57 # allow topic level compression
58 #compressed.topics=
59
60 ############################# Async Producer #############################
61 # maximum time, in milliseconds, for buffering data on the producer queue 
62 #queue.buffering.max.ms=
63
64 # the maximum size of the blocking queue for buffering on the producer 
65 #queue.buffering.max.messages=
66
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=
72
73 # the number of messages batched at the producer 
74 #batch.num.messages=