Skip to content

Commit

Permalink
[MODINVOSTO-187] Temp
Browse files Browse the repository at this point in the history
  • Loading branch information
Saba-Zedginidze-EPAM committed Nov 7, 2024
1 parent 7a111f4 commit eb81388
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ private Future<Void> sendToKafka(EventTopic eventTopic, String key, Object event

var producerManager = new SimpleKafkaProducerManager(Vertx.currentContext().owner(), kafkaConfig);
KafkaProducer<String, String> producer = producerManager.createShared(topicName);
log.debug("sendToKafka:: Sending event for {} with id '{}' to kafka topic '{}' with url: '{}'", eventTopic, key, topicName, kafkaConfig.getKafkaUrl());
log.info("sendToKafka:: Sending event for {} with id '{}' to kafka topic '{}' with url: '{}'", eventTopic, key, topicName, kafkaConfig.getKafkaUrl());
return producer.send(kafkaProducerRecord)
.onComplete(reply -> producer.end(ear -> producer.close()))
.onSuccess(s -> log.info("sendToKafka:: Event for {} with id '{}' has been sent to kafka topic '{}'", eventTopic, key, topicName))
Expand Down

0 comments on commit eb81388

Please sign in to comment.