[camel-quarkus] branch quarkus-main updated: Adapt to io.quarkus.kafka.client.runtime.KafkaRuntimeConfigProducer.createKafkaRuntimeConfig() switching from @Named to @Identifier

[ppalaga]

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


The following commit(s) were added to refs/heads/quarkus-main by this push:
     new b4698b9  Adapt to 
io.quarkus.kafka.client.runtime.KafkaRuntimeConfigProducer.createKafkaRuntimeConfig()
 switching from @Named to @Identifier
b4698b9 is described below

commit b4698b97bbf2c2dc8d0fbf54909193e1360104e0
Author: Peter Palaga <ppal...@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);