Skip to content

Commit 6884336

Browse files
committed
Use random positive int for Debezium database.server.id connector prop
1 parent c4ec7d5 commit 6884336

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

spring-integration-debezium/src/test/java/org/springframework/integration/debezium/DebeziumMySqlTestContainer.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818

1919
import java.util.Properties;
2020
import java.util.UUID;
21+
import java.util.concurrent.ThreadLocalRandom;
2122

2223
import org.junit.jupiter.api.BeforeAll;
2324
import org.testcontainers.containers.MySQLContainer;
@@ -70,7 +71,7 @@ static Properties connectorConfig(int port) {
7071
// Topic prefix for the database server or cluster.
7172
config.put("topic.prefix", "my-topic-" + uuid);
7273
// Unique ID of the connector.
73-
config.put("database.server.id", "" + (uuid.getMostSignificantBits() & Long.MAX_VALUE));
74+
config.put("database.server.id", "" + Math.abs(ThreadLocalRandom.current().nextInt()));
7475

7576
config.put("key.converter.schemas.enable", "false");
7677
config.put("value.converter.schemas.enable", "false");

0 commit comments

Comments
 (0)