Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use random positive int for Debezium database.server.id connector prop

Browse Source
This commit is contained in:
Artem Bilan
2024-07-16 14:16:58 -04:00
parent c4ec7d5f22
commit 68843362d8
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -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");