diff --git a/src/main/java/biz/nynja/account/kafka/KafkaProducerConfig.java b/src/main/java/biz/nynja/account/kafka/KafkaProducerConfig.java index 64d0edd8c52fa03031a419b8ad75a718cc552727..19858b92a7ad726d0abb0a349aa8048176a0a1fc 100644 --- a/src/main/java/biz/nynja/account/kafka/KafkaProducerConfig.java +++ b/src/main/java/biz/nynja/account/kafka/KafkaProducerConfig.java @@ -15,8 +15,10 @@ import org.springframework.kafka.core.DefaultKafkaProducerFactory; import org.springframework.kafka.core.KafkaTemplate; import org.springframework.kafka.core.ProducerFactory; import org.springframework.kafka.support.serializer.JsonSerializer; +import org.springframework.scheduling.annotation.EnableAsync; @Configuration +@EnableAsync public class KafkaProducerConfig { @Value("${kafka.host}") diff --git a/src/main/java/biz/nynja/account/kafka/UserEventsProducer.java b/src/main/java/biz/nynja/account/kafka/UserEventsProducer.java index 1d087de05f2c48a2f21a9befd276b234b86e962c..6ffe9509e92886a13e34031c7d4099855d6ddc2a 100644 --- a/src/main/java/biz/nynja/account/kafka/UserEventsProducer.java +++ b/src/main/java/biz/nynja/account/kafka/UserEventsProducer.java @@ -8,6 +8,7 @@ import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.kafka.core.KafkaTemplate; +import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Component; @Component @@ -22,6 +23,7 @@ public class UserEventsProducer { @Qualifier("kafkaTopic") private String kafkaTopic; + @Async public void sendKafkaMessage(UserEventsMessageTemplate userEventsMessageTemplate) { kafkaTemplate.send(kafkaTopic, userEventsMessageTemplate); diff --git a/src/main/resources/application-production.yml b/src/main/resources/application-production.yml index f832bac4461860bcf4f42cc040e23d953f87edc8..a4ad9c16c98b85e344a6d1a10c464adb70f18fb9 100644 --- a/src/main/resources/application-production.yml +++ b/src/main/resources/application-production.yml @@ -40,7 +40,7 @@ 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} + max-block-ms: ${KAFKA_MAX_BLOCK_MS:1000} reconnect-backoff-ms: ${KAFKA_RECONNECT_BACKOFF_MS:10000} #Metrics related configurations