From d2877ee641ba8c82c994dbef033ae9aab643871e Mon Sep 17 00:00:00 2001
From: Vojtech Juranek <vjuranek@redhat.com>
Date: Mon, 12 Aug 2024 12:29:14 +0200
Subject: [PATCH] DBZ-8134 Fix parsing of server ID

---
 .../connector/binlog/BinlogConnectorConfig.java       |  2 +-
 .../debezium/connector/binlog/BinlogConnectorIT.java  | 11 +++++++++++
 2 files changed, 12 insertions(+), 1 deletion(-)

diff --git a/debezium-connector-binlog/src/main/java/io/debezium/connector/binlog/BinlogConnectorConfig.java b/debezium-connector-binlog/src/main/java/io/debezium/connector/binlog/BinlogConnectorConfig.java
index 88af9ef55..0f4e78d10 100644
--- a/debezium-connector-binlog/src/main/java/io/debezium/connector/binlog/BinlogConnectorConfig.java
+++ b/debezium-connector-binlog/src/main/java/io/debezium/connector/binlog/BinlogConnectorConfig.java
@@ -832,7 +832,7 @@ public String getPassword() {
      * @return the database cluster server unique identifier
      */
     public long getServerId() {
-        return config.getInteger(SERVER_ID);
+        return config.getLong(SERVER_ID);
     }
 
     /**
diff --git a/debezium-connector-binlog/src/test/java/io/debezium/connector/binlog/BinlogConnectorIT.java b/debezium-connector-binlog/src/test/java/io/debezium/connector/binlog/BinlogConnectorIT.java
index acd680e7d..f385a8948 100644
--- a/debezium-connector-binlog/src/test/java/io/debezium/connector/binlog/BinlogConnectorIT.java
+++ b/debezium-connector-binlog/src/test/java/io/debezium/connector/binlog/BinlogConnectorIT.java
@@ -2699,6 +2699,17 @@ public void shouldEmitTruncateOperation() throws Exception {
         stopConnector();
     }
 
+    @Test
+    @FixFor("DBZ-8134")
+    public void shouldAcceptLongAsServerId() throws InterruptedException {
+        Configuration config = DATABASE.defaultConfig()
+                .with(BinlogConnectorConfig.SERVER_ID, "202309181059")
+                .build();
+        start(getConnectorClass(), config);
+        waitForStreamingRunning(DATABASE.getServerName());
+        stopConnector();
+    }
+
     protected String getExpectedQuery(String statement) {
 
         return statement;