search

micronaut-projects / micronaut-kafka

Integration between Micronaut and Apache Kafka
Apache License 2.0
83 stars 104 forks source link

Add executor configuration for KafkaClient #955

Closed jeremyg484 closed 7 months ago

jeremyg484 commented 8 months ago

An executor configuration parameter is added to AbstractKafkaProducerConfiguration and the KafkaClient annotation to allow an executor to be used to enable fully non-blocking reactive and CompletableFuture producer methods.

The new configuration is used by KafkaClientIntroductionAdvice to retrieve the corresponding ExecutorService and use it to make the introduced method implementations non-blocking wherever possible by offloading the blocking KafkaProducer calls to a separate thread from that of the caller.

Resolves #480

CLAassistant commented 7 months ago

CLA assistant check
All committers have signed the CLA.

sonarcloud[bot] commented 7 months ago

Quality Gate Failed Quality Gate failed

Failed conditions
36.4% Coverage on New Code (required ≥ 70%)
1 New Critical Issues (required ≤ 0)

See analysis details on SonarCloud

idea Catch issues before they fail your Quality Gate with our IDE extension SonarLint SonarLint