alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-6522 Revert test changes for shouldFailWithoutPermissions()

Browse Source
This commit is contained in:
ani-sha 2024-06-19 11:07:12 +05:30 committed by Jakub Cechacek
parent 5f6f40d591
commit 1315a857f9
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/MongoDbConnectorDatabaseRestrictedIT.java
View File

@ -15,6 +15,7 @@
import org.apache.kafka.connect.data.Struct;
import org.apache.kafka.connect.source.SourceRecord;
import org.assertj.core.api.Assertions;
import org.awaitility.Awaitility;
import org.bson.Document;
import org.junit.After;
@ -32,13 +33,13 @@
import io.debezium.config.CommonConnectorConfig;
import io.debezium.config.Configuration;
import io.debezium.connector.mongodb.MongoDbConnectorConfig.CaptureScope;
import io.debezium.connector.mongodb.connection.MongoDbConnections;
import io.debezium.connector.mongodb.junit.MongoDbDatabaseProvider;
import io.debezium.connector.mongodb.junit.MongoDbDatabaseVersionResolver;
import io.debezium.connector.mongodb.junit.MongoDbPlatform;
import io.debezium.data.Envelope;
import io.debezium.embedded.AbstractConnectorTest;
import io.debezium.junit.logging.LogInterceptor;
import io.debezium.pipeline.ErrorHandler;
import io.debezium.testing.testcontainers.MongoDbReplicaSet;
import io.debezium.testing.testcontainers.util.DockerUtils;
@ -158,7 +159,7 @@ public void shouldConsumeAllEventsFromDatabaseWithPermissions() throws Interrupt
@Test
public void shouldFailWithoutPermissions() {
var logInterceptor = new LogInterceptor(MongoDbConnections.class);
var logInterceptor = new LogInterceptor(ErrorHandler.class);
// Populate collection
populateCollection(TEST_DATABASE, TEST_COLLECTION, INIT_DOCUMENT_COUNT);
@ -169,12 +170,9 @@ public void shouldFailWithoutPermissions() {
// Start the connector ...
start(MongoDbConnector.class, config);
// Connector should fail while authenticating with the database
Awaitility.await().atMost(10, TimeUnit.SECONDS)
.until(() -> logInterceptor.containsMessage("Error while attempting to Setting resume token"));
// Connector should fail after 2 retries
// Awaitility.await().pollDelay(10, TimeUnit.SECONDS).timeout(30, TimeUnit.SECONDS).until(() -> !isEngineRunning.get());
// Assertions.assertThat(logInterceptor.containsMessage("The maximum number of 2 retries has been attempted")).isTrue();
Awaitility.await().pollDelay(10, TimeUnit.SECONDS).timeout(30, TimeUnit.SECONDS).until(() -> !isEngineRunning.get());
Assertions.assertThat(logInterceptor.containsMessage("The maximum number of 2 retries has been attempted")).isTrue();
}
protected void consumeAndVerifyFromInitialSnapshot(String topic, int expectedRecords) throws InterruptedException {