Skip to content

Commit 9752229

Browse files
committed
Use UUID in Debezium tests for unique ids
1 parent 33f0b8e commit 9752229

File tree

1 file changed

+5
-6
lines changed

1 file changed

+5
-6
lines changed

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

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
package org.springframework.integration.debezium;
1818

1919
import java.util.Properties;
20-
import java.util.Random;
20+
import java.util.UUID;
2121

2222
import org.testcontainers.containers.GenericContainer;
2323
import org.testcontainers.containers.wait.strategy.LogMessageWaitStrategy;
@@ -48,8 +48,6 @@ static int mysqlPort() {
4848
}
4949

5050
static Properties connectorConfig(int port) {
51-
Random random = new Random();
52-
5351
Properties config = new Properties();
5452

5553
config.put("transforms", "unwrap");
@@ -62,12 +60,13 @@ static Properties connectorConfig(int port) {
6260
config.put("schema.history.internal", "io.debezium.relational.history.MemorySchemaHistory");
6361
config.put("offset.storage", "org.apache.kafka.connect.storage.MemoryOffsetBackingStore");
6462

65-
config.put("name", "my-connector-" + random.nextInt(10));
63+
UUID uuid = UUID.randomUUID();
64+
config.put("name", "my-connector-" + uuid);
6665

6766
// Topic prefix for the database server or cluster.
68-
config.put("topic.prefix", "my-topic-" + random.nextInt(10));
67+
config.put("topic.prefix", "my-topic-" + uuid);
6968
// Unique ID of the connector.
70-
config.put("database.server.id", "8574" + random.nextInt(10));
69+
config.put("database.server.id", "" + (uuid.getMostSignificantBits() & Long.MAX_VALUE));
7170

7271
config.put("key.converter.schemas.enable", "false");
7372
config.put("value.converter.schemas.enable", "false");

0 commit comments

Comments
 (0)