You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@plc4x.apache.org by hu...@apache.org on 2022/05/15 21:42:17 UTC
[plc4x] branch develop updated: fix(plc4j): Kafka Connector fail to find transport fix
This is an automated email from the ASF dual-hosted git repository.
hutcheb pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git
The following commit(s) were added to refs/heads/develop by this push:
new 63db99c6ce fix(plc4j): Kafka Connector fail to find transport fix
63db99c6ce is described below
commit 63db99c6ce759b2933bfc813712096186bebb627
Author: Ben Hutcheson <be...@gmail.com>
AuthorDate: Mon May 16 07:41:35 2022 +1000
fix(plc4j): Kafka Connector fail to find transport fix
---
.../src/main/java/org/apache/plc4x/kafka/Plc4xSourceTask.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/Plc4xSourceTask.java b/plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/Plc4xSourceTask.java
index 5881328209..33690485bc 100644
--- a/plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/Plc4xSourceTask.java
+++ b/plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/Plc4xSourceTask.java
@@ -34,7 +34,7 @@ import org.apache.plc4x.java.scraper.exception.ScraperException;
import org.apache.plc4x.java.scraper.triggeredscraper.TriggeredScraperImpl;
import org.apache.plc4x.java.scraper.triggeredscraper.triggerhandler.collector.TriggerCollector;
import org.apache.plc4x.java.scraper.triggeredscraper.triggerhandler.collector.TriggerCollectorImpl;
-import org.apache.plc4x.java.utils.connectionpool2.PooledDriverManager;
+import org.apache.plc4x.java.utils.connectionpool2.CachedDriverManager;
import org.apache.plc4x.kafka.config.Constants;
import org.apache.plc4x.kafka.util.VersionUtil;
import org.slf4j.Logger;
@@ -152,7 +152,8 @@ public class Plc4xSourceTask extends SourceTask {
ScraperConfigurationTriggeredImpl scraperConfig = builder.build();
try {
- PlcDriverManager plcDriverManager = new PooledDriverManager();
+ PlcDriverManager manager = new PlcDriverManager();
+ PlcDriverManager plcDriverManager = new CachedDriverManager(plc4xConnectionString,() -> manager.getConnection(plc4xConnectionString));
TriggerCollector triggerCollector = new TriggerCollectorImpl(plcDriverManager);
scraper = new TriggeredScraperImpl(scraperConfig, (jobName, sourceName, results) -> {
try {