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

Attempt to fix Debezium tests

Browse Source
This commit is contained in:
Artem Bilan
2024-07-16 13:35:15 -04:00
parent 42f4579b2a
commit eac8c31a1d
3 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1,5 +1,5 @@
/*
* Copyright 2023-2023 the original author or authors.
* Copyright 2023-2024 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -37,7 +37,7 @@ public interface DebeziumMySqlTestContainer {
MySQLContainer<?> DEBEZIUM_MYSQL =
new MySQLContainer<>(
DockerImageName.parse("debezium/example-mysql:2.2.0.Final")
DockerImageName.parse("debezium/example-mysql:2.7.0.Final")
.asCompatibleSubstituteFor("mysql"))
.withUsername("mysqluser")
.withPassword("mysqlpw");

5
spring-integration-debezium/src/test/java/org/springframework/integration/debezium/it/DebeziumBatchTests.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2023-2023 the original author or authors.
* Copyright 2023-2024 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -16,6 +16,7 @@
package org.springframework.integration.debezium.it;
import java.time.Duration;
import java.util.ArrayList;
import java.util.List;
@@ -62,7 +63,7 @@ public class DebeziumBatchTests implements DebeziumMySqlTestContainer {
@Test
void batchMode() {
await().until(this::receivePayloads, (count) -> count == EXPECTED_DB_TX_COUNT);
await().atMost(Duration.ofSeconds(30)).until(this::receivePayloads, (count) -> count == EXPECTED_DB_TX_COUNT);
assertThat(allPayload).hasSize(EXPECTED_DB_TX_COUNT);
assertThat(batchCount).isLessThan(EXPECTED_DB_TX_COUNT);

4
spring-integration-debezium/src/test/java/org/springframework/integration/debezium/it/DebeziumStreamTests.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2023-2023 the original author or authors.
* Copyright 2023-2024 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -56,7 +56,7 @@ public class DebeziumStreamTests implements DebeziumMySqlTestContainer {
void streamMode() {
boolean foundDebeziumHeaders = false;
for (int i = 0; i < EXPECTED_DB_TX_COUNT; i++) {
Message<?> message = this.queueChannel.receive(10_000);
Message<?> message = this.queueChannel.receive(30_000);
assertThat(message).isNotNull();
if (message.getHeaders().size() > 5) {