diff --git a/src/main/java/biz/nynja/account/kafka/KafkaProducerConfig.java b/src/main/java/biz/nynja/account/kafka/KafkaProducerConfig.java
index b9f2ebc2cd176cf6e2e1e84a0dec842941df02fe..64d0edd8c52fa03031a419b8ad75a718cc552727 100644
--- a/src/main/java/biz/nynja/account/kafka/KafkaProducerConfig.java
+++ b/src/main/java/biz/nynja/account/kafka/KafkaProducerConfig.java
@@ -25,6 +25,10 @@ public class KafkaProducerConfig {
     private String KAFKA_PORT;
     @Value("${kafka.topic}")
     private String KAFKA_TOPIC;
+    @Value("${kafka.max-block-ms}")
+    private String KAFKA_MAX_BLOCK_MS;
+    @Value("${kafka.reconnect-backoff-ms}")
+    private String KAFKA_RECONNECT_BACKOFF_MS;
 
     @Bean(name = "kafkaTopic")
     public String kafkaTopic() {
@@ -42,6 +46,9 @@ public class KafkaProducerConfig {
         configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
         configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
 
+        configProps.put(ProducerConfig.RECONNECT_BACKOFF_MS_CONFIG, KAFKA_RECONNECT_BACKOFF_MS); // The base amount of time to wait before attempting to reconnect to a given host. default=50L
+        configProps.put(ProducerConfig.MAX_BLOCK_MS_CONFIG, KAFKA_MAX_BLOCK_MS);
+
         return new DefaultKafkaProducerFactory<String, UserEventsMessageTemplate>(configProps);
 
     }
diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml
index 879dcbaa39ecec1afa858e09adc1da683f827298..b890db9e3baa2c4504b009b944165d80445048be 100644
--- a/src/main/resources/application-dev.yml
+++ b/src/main/resources/application-dev.yml
@@ -47,6 +47,8 @@ kafka:
   host: 127.0.0.1
   port: 9092
   topic: userEventss
+  max-block-ms: 1000
+  reconnect-backoff-ms: 10000
 
 #Metrics related configurations
 management:
diff --git a/src/main/resources/application-production.yml b/src/main/resources/application-production.yml
index f97fa408ddd1337766799ba344708638a7ba8351..f832bac4461860bcf4f42cc040e23d953f87edc8 100644
--- a/src/main/resources/application-production.yml
+++ b/src/main/resources/application-production.yml
@@ -40,6 +40,8 @@ kafka:
   host: ${KAFKA_HOST:kafka.kafka.svc.cluster.local}
   port: ${KAFKA_PORT:9092}
   topic: ${KAFKA_TOPIC:userEvents}
+  max-block-ms: ${KAFKA_MAX_BLOCK_MS:700}
+  reconnect-backoff-ms: ${KAFKA_RECONNECT_BACKOFF_MS:10000}
 
 #Metrics related configurations
 management: