INNER CODE UNIT · Java

ChangeStreamRoundTripTest

mongodb/mongo-kafka · src/integrationTest/java/com/mongodb/kafka/connect/ChangeStreamRoundTripTest.java:57

public class ChangeStreamRoundTripTest extends MongoKafkaTestCase {

  @BeforeEach
  void setUp() {
    assumeTrue(isReplicaSetOrSharded());
    cleanUp();
  }

  @AfterEach
  void tearDown() {
    cleanUp();
  }

  @Test
  @DisplayName("Ensure collection CRUD operations can be round tripped")
  void testRoundTripCollectionCrud() {
    MongoDatabase original = getDatabaseWithPostfix();
    MongoDatabase replicated = getDatabaseWithPostfix();

View source record →