From 4ce401d2196c4616400a4b730b047b8f19b89ef6 Mon Sep 17 00:00:00 2001 From: mikoto Date: Sat, 9 Oct 2021 15:38:26 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=A4=9Adestination=E7=9A=84=E5=9C=BA?= =?UTF-8?q?=E6=99=AF=E4=B8=8B=E5=8F=AA=E8=83=BD=E7=94=9F=E6=95=88=E4=B8=80?= =?UTF-8?q?=E4=B8=AA=20(#3772)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../otter/canal/adapter/launcher/loader/AdapterProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/AdapterProcessor.java b/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/AdapterProcessor.java index 85601cd5..f70095a5 100644 --- a/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/AdapterProcessor.java +++ b/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/AdapterProcessor.java @@ -63,7 +63,7 @@ public class AdapterProcessor { // load connector consumer ExtensionLoader loader = new ExtensionLoader<>(CanalMsgConsumer.class); canalMsgConsumer = loader - .getExtension(canalClientConfig.getMode().toLowerCase(), CONNECTOR_SPI_DIR, CONNECTOR_STANDBY_SPI_DIR); + .getExtension(canalClientConfig.getMode().toLowerCase(),destination ,CONNECTOR_SPI_DIR, CONNECTOR_STANDBY_SPI_DIR); Properties properties = canalClientConfig.getConsumerProperties(); properties.put(CanalConstants.CANAL_MQ_FLAT_MESSAGE, canalClientConfig.getFlatMessage());