# list of brokers used for bootstrapping knowledge about the rest of the cluster
# format: host1:port1,host2:port2 ...
bootstrap.servers=broker5.local:6667,broker4.local:6667,broker3.local:6667,broker2.local:6667,broker1.local:6667

# specify the compression codec for all data generated: none, gzip, snappy, lz4
compression.type=gzip

# name of the partitioner class for partitioning events; default partition spreads data randomly
#partitioner.class=

# the maximum amount of time the client will wait for the response of a request
request.timeout.ms=60000

# how long `KafkaProducer.send` and `KafkaProducer.partitionsFor` will block for
#max.block.ms=

# the producer will wait for up to the given delay to allow other records to be sent so that the sends can be batched together
linger.ms=100

# the maximum size of a request in bytes
max.request.size=4194304

# the default batch size in bytes when batching multiple records sent to a partition
batch.size=32768

# the total bytes of memory the producer can use to buffer records waiting to be sent to the server
buffer.memory=100000000

# Retry count when sending failure.
retries=10

# The number of acknowledgments the producer requires the leader to have received before considering a request complete
# broker setting min.insync.replicas=3
ack=all

# Exactly one copy of each message is written in the stream
enable.idempotence=true

# Serializer class for key that implements the Serializer interface.
key.serializer=org.apache.kafka.common.serialization.ByteArraySerializer

# Serializer class for value that implements the Serializer interface.
value.serializer=org.apache.kafka.common.serialization.ByteArraySerializer