From 4cac208f98f78ea878754f0b1e831ac458d19467 Mon Sep 17 00:00:00 2001
From: Urban Malc <urban.malc@cloud.si>
Date: Fri, 15 Mar 2019 11:54:29 +0100
Subject: [PATCH] Fixed wrong cache usage

---
 .../ee/streaming/kafka/utils/producer/KafkaProducerFactory.java | 2 +-
 1 file changed, 1 insertion(+), 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
index 196f77f..b5dcef8 100644
--- 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())) {