From 202a90846b86e7da5780aec15f7fdd754e094f91 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Wed, 7 Sep 2022 15:29:46 +0200
Subject: [PATCH] Update kafka producer

---
 src/main/java/it/tdlight/reactiveapi/KafkaProducer.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/main/java/it/tdlight/reactiveapi/KafkaProducer.java b/src/main/java/it/tdlight/reactiveapi/KafkaProducer.java
index fa4560a..0b8bba8 100644
--- a/src/main/java/it/tdlight/reactiveapi/KafkaProducer.java
+++ b/src/main/java/it/tdlight/reactiveapi/KafkaProducer.java
@@ -26,7 +26,9 @@ public abstract class KafkaProducer<K> {
 		Map<String, Object> props = new HashMap<>();
 		props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaParameters.bootstrapServers());
 		props.put(ProducerConfig.CLIENT_ID_CONFIG, kafkaParameters.clientId());
-		props.put(ProducerConfig.ACKS_CONFIG, "all");
+		props.put(ProducerConfig.ACKS_CONFIG, "1");
+		props.put(ProducerConfig.BATCH_SIZE_CONFIG, 16384);
+		props.put(ProducerConfig.COMPRESSION_TYPE_CONFIG, "snappy");
 		props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, IntegerSerializer.class);
 		props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, getChannelName().getSerializerClass());
 		SenderOptions<Integer, K> senderOptions = SenderOptions.create(props);