Fixed wrong cache usage

kumuluz · Mar 15, 2019 · 4cac208 · 4cac208
1 parent bf8ddb7
commit 4cac208
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/src/main/java/com/kumuluz/ee/streaming/kafka/utils/producer/KafkaProducerFactory.java b/kafka/src/main/java/com/kumuluz/ee/streaming/kafka/utils/producer/KafkaProducerFactory.java
@@ -99,7 +99,7 @@ public Producer getProducer(InjectionPoint injectionPoint) {
                 producers.put(config, producer);
             }
 
-            return producersWithConfigOverrides.get(injectionPoint.getAnnotated());
+            return producers.get(config);
         } else {
             // cache by injection point if overrides present
             if (!producersWithConfigOverrides.containsKey(injectionPoint.getAnnotated())) {