Fix Kafka serde autodetection for outgoing @channel injection points

quarkusio · Jun 9, 2021 · 3beeb70 · 3beeb70
1 parent d9d50a2
commit 3beeb70
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/.../smallrye/reactivemessaging/kafka/deployment/SmallRyeReactiveMessagingKafkaProcessor.java b/.../smallrye/reactivemessaging/kafka/deployment/SmallRyeReactiveMessagingKafkaProcessor.java
@@ -98,7 +98,8 @@ void discoverDefaultSerdeConfig(DefaultSerdeDiscoveryState discovery,
 
         for (AnnotationInstance annotation : discovery.findAnnotationsOnInjectionPoints(DotNames.CHANNEL)) {
             String channelName = annotation.value().asString();
-            if (!discovery.isKafkaConnector(false, channelName)) {
+            if (!discovery.isKafkaConnector(false, channelName)
+                    && !discovery.isKafkaConnector(true, channelName)) {
                 continue;
             }