From 259008a7cd6a213315a9b19549414a2c58cd3695 Mon Sep 17 00:00:00 2001
From: "jianghang.loujh" <jianghang.loujh@alibaba-inc.com>
Date: Fri, 3 Nov 2023 10:39:17 +0800
Subject: [PATCH] update config

---
 .../otter/canal/client/kafka/KafkaCanalConnector.java        | 5 ++---
 deployer/src/main/resources/canal.properties                 | 2 ++
 docker/build.sh                                              | 2 +-
 3 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/client/src/main/java/com/alibaba/otter/canal/client/kafka/KafkaCanalConnector.java b/client/src/main/java/com/alibaba/otter/canal/client/kafka/KafkaCanalConnector.java
index e7d46370..0125614a 100644
--- a/client/src/main/java/com/alibaba/otter/canal/client/kafka/KafkaCanalConnector.java
+++ b/client/src/main/java/com/alibaba/otter/canal/client/kafka/KafkaCanalConnector.java
@@ -1,6 +1,5 @@
 package com.alibaba.otter.canal.client.kafka;
 
-import com.alibaba.fastjson2.JSON;
 import java.util.*;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.TimeUnit;
@@ -11,6 +10,7 @@ import org.apache.kafka.clients.consumer.KafkaConsumer;
 import org.apache.kafka.common.TopicPartition;
 import org.apache.kafka.common.serialization.StringDeserializer;
 
+import com.alibaba.fastjson2.JSON;
 import com.alibaba.otter.canal.client.CanalMQConnector;
 import com.alibaba.otter.canal.client.impl.SimpleCanalConnector;
 import com.alibaba.otter.canal.protocol.FlatMessage;
@@ -43,7 +43,7 @@ public class KafkaCanalConnector implements CanalMQConnector {
     private Map<Integer, Long>               currentOffsets = new ConcurrentHashMap<>();
 
     public KafkaCanalConnector(String servers, String topic, Integer partition, String groupId, Integer batchSize,
-        boolean flatMessage){
+                               boolean flatMessage){
         this.topic = topic;
         this.partition = partition;
         this.flatMessage = flatMessage;
@@ -324,4 +324,3 @@ public class KafkaCanalConnector implements CanalMQConnector {
     }
 
 }
-
diff --git a/deployer/src/main/resources/canal.properties b/deployer/src/main/resources/canal.properties
index e6bdc4cc..2586a60a 100644
--- a/deployer/src/main/resources/canal.properties
+++ b/deployer/src/main/resources/canal.properties
@@ -176,6 +176,8 @@ rabbitmq.virtual.host =
 rabbitmq.exchange =
 rabbitmq.username =
 rabbitmq.password =
+rabbitmq.queue =
+rabbitmq.routingKey =
 rabbitmq.deliveryMode =
 
 
diff --git a/docker/build.sh b/docker/build.sh
index 7df4c52d..b3f7d9ef 100644
--- a/docker/build.sh
+++ b/docker/build.sh
@@ -25,5 +25,5 @@ else
     cd $BASE/../ && mvn clean package -Dmaven.test.skip -Denv=release && cd $current_path ;
     cp $BASE/../target/canal.deployer-*.tar.gz $BASE/
     docker build --no-cache -t canal/canal-server $BASE/
-    # docker build -platform linux/arm64 --no-cache -t canal/canal-server $BASE/
+    # docker build --platform linux/arm64 --no-cache -t canal/canal-server $BASE/
 fi