You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by pp...@apache.org on 2021/06/18 10:19:40 UTC
[camel-quarkus] 02/02: Adapt to
io.quarkus.kafka.client.runtime.KafkaRuntimeConfigProducer.createKafkaRuntimeConfig()
switching from @Named to @Identifier
This is an automated email from the ASF dual-hosted git repository.
ppalaga pushed a commit to branch quarkus-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 44929d930fa229cd9eb953dc932edc2db95d01a9
Author: Peter Palaga <pp...@redhat.com>
AuthorDate: Fri Jun 18 12:17:36 2021 +0200
Adapt to io.quarkus.kafka.client.runtime.KafkaRuntimeConfigProducer.createKafkaRuntimeConfig() switching from @Named to @Identifier
---
.../quarkus/component/kafka/CamelKafkaRecorder.java | 18 ++++++++++--------
1 file changed, 10 insertions(+), 8 deletions(-)
diff --git a/extensions/kafka/runtime/src/main/java/org/apache/camel/quarkus/component/kafka/CamelKafkaRecorder.java b/extensions/kafka/runtime/src/main/java/org/apache/camel/quarkus/component/kafka/CamelKafkaRecorder.java
index df50206..b931ed6 100644
--- a/extensions/kafka/runtime/src/main/java/org/apache/camel/quarkus/component/kafka/CamelKafkaRecorder.java
+++ b/extensions/kafka/runtime/src/main/java/org/apache/camel/quarkus/component/kafka/CamelKafkaRecorder.java
@@ -19,25 +19,27 @@ package org.apache.camel.quarkus.component.kafka;
import java.util.Collections;
import java.util.Map;
+import javax.enterprise.util.TypeLiteral;
+
import io.quarkus.arc.Arc;
import io.quarkus.arc.InstanceHandle;
import io.quarkus.runtime.RuntimeValue;
import io.quarkus.runtime.annotations.Recorder;
+import io.smallrye.common.annotation.Identifier;
import org.apache.camel.component.kafka.KafkaClientFactory;
@Recorder
public class CamelKafkaRecorder {
- @SuppressWarnings("unchecked")
public RuntimeValue<KafkaClientFactory> createKafkaClientFactory() {
- final InstanceHandle<Object> instance = Arc.container().instance("default-kafka-broker");
- Map<String, Object> kafkaConfig;
+ @SuppressWarnings("serial")
+ final InstanceHandle<Map<String, Object>> instance = Arc.container()
+ .instance(
+ new TypeLiteral<Map<String, Object>>() {
+ },
+ Identifier.Literal.of("default-kafka-broker"));
- if (instance.isAvailable()) {
- kafkaConfig = (Map<String, Object>) instance.get();
- } else {
- kafkaConfig = Collections.emptyMap();
- }
+ final Map<String, Object> kafkaConfig = instance.isAvailable() ? instance.get() : Collections.emptyMap();
QuarkusKafkaClientFactory quarkusKafkaClientFactory = new QuarkusKafkaClientFactory(kafkaConfig);
return new RuntimeValue<>(quarkusKafkaClientFactory);