From b63c28c68a0d6765ded7e870984ebb911e2fdc6f Mon Sep 17 00:00:00 2001 From: Angel Botev Date: Mon, 19 Aug 2019 12:08:05 +0300 Subject: [PATCH] Send message to kafka async Signed-off-by: Angel Botev --- src/main/java/biz/nynja/account/kafka/KafkaProducerConfig.java | 2 ++ src/main/java/biz/nynja/account/kafka/UserEventsProducer.java | 2 ++ src/main/resources/application-production.yml | 2 +- 3 files changed, 5 insertions(+), 1 deletion(-) diff --git a/src/main/java/biz/nynja/account/kafka/KafkaProducerConfig.java b/src/main/java/biz/nynja/account/kafka/KafkaProducerConfig.java index 64d0edd..19858b9 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 1d087de..6ffe950 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 f832bac..a4ad9c1 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 -- GitLab