From 68843362d8ff70bbaa9f3e426b1545c0591499b7 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 16 Jul 2024 14:16:58 -0400 Subject: [PATCH] Use random positive int for Debezium `database.server.id` connector prop --- .../integration/debezium/DebeziumMySqlTestContainer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/spring-integration-debezium/src/test/java/org/springframework/integration/debezium/DebeziumMySqlTestContainer.java b/spring-integration-debezium/src/test/java/org/springframework/integration/debezium/DebeziumMySqlTestContainer.java index 86df2697c7..80d6c318ab 100644 --- a/spring-integration-debezium/src/test/java/org/springframework/integration/debezium/DebeziumMySqlTestContainer.java +++ b/spring-integration-debezium/src/test/java/org/springframework/integration/debezium/DebeziumMySqlTestContainer.java @@ -18,6 +18,7 @@ package org.springframework.integration.debezium; import java.util.Properties; import java.util.UUID; +import java.util.concurrent.ThreadLocalRandom; import org.junit.jupiter.api.BeforeAll; import org.testcontainers.containers.MySQLContainer; @@ -70,7 +71,7 @@ public interface DebeziumMySqlTestContainer { // Topic prefix for the database server or cluster. config.put("topic.prefix", "my-topic-" + uuid); // Unique ID of the connector. - config.put("database.server.id", "" + (uuid.getMostSignificantBits() & Long.MAX_VALUE)); + config.put("database.server.id", "" + Math.abs(ThreadLocalRandom.current().nextInt())); config.put("key.converter.schemas.enable", "false"); config.put("value.converter.schemas.enable", "false");