test(jikkou): update integration-tests for topics

streamthoughts · Jan 17, 2022 · 53b7007 · 53b7007
1 parent 91c8142
commit 53b7007
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/.../io/streamthoughts/kafka/specs/manager/adminclient/AdminClientKafkaTopicManagerITest.java b/.../io/streamthoughts/kafka/specs/manager/adminclient/AdminClientKafkaTopicManagerITest.java
@@ -25,7 +25,7 @@
 import io.streamthoughts.kafka.specs.config.JikkouConfig;
 import io.streamthoughts.kafka.specs.io.SpecFileLoader;
 import io.streamthoughts.kafka.specs.manager.KafkaResourceManager;
-import io.streamthoughts.kafka.specs.manager.KafkaResourceOperationContext;
+import io.streamthoughts.kafka.specs.manager.KafkaResourceUpdateContext;
 import io.streamthoughts.kafka.specs.manager.KafkaTopicManager;
 import io.streamthoughts.kafka.specs.manager.TopicDescribeOptions;
 import io.streamthoughts.kafka.specs.model.V1SpecFile;
@@ -57,6 +57,7 @@ public class AdminClientKafkaTopicManagerITest {
             new RedpandaContainerConfig()
                     .withKafkaApiFixedExposedPort(9092)
                     .withAttachContainerOutputLog(true)
+                    .withTransactionEnabled(false)
     );
 
     private KafkaTopicManager manager;
@@ -82,7 +83,7 @@ public void should_update_kafka_topic_using_admin_client_given_create_only() {
         manager.update(
                 KafkaResourceManager.UpdateMode.CREATE_ONLY,
                 List.of(file.specs()),
-                KafkaResourceOperationContext.with(new TopicChangeOptions(), false)
+                KafkaResourceUpdateContext.with(new TopicChangeOptions(), false)
         );
 
         // Then
@@ -127,7 +128,7 @@ public void should_update_kafka_topic_using_admin_client_given_delete_only() {
         Collection<ChangeResult<TopicChange>> results = manager.update(
                 KafkaResourceManager.UpdateMode.DELETE_ONLY,
                 List.of(new V1SpecsObject()),
-                KafkaResourceOperationContext.with(options, false)
+                KafkaResourceUpdateContext.with(options, false)
         );
 
         // Then
@@ -158,7 +159,7 @@ public void should_update_kafka_topic_using_admin_client_given_alter_only() {
         Collection<ChangeResult<TopicChange>> results = manager.update(
                 KafkaResourceManager.UpdateMode.ALTER_ONLY,
                 objects,
-                KafkaResourceOperationContext.with(options, false)
+                KafkaResourceUpdateContext.with(options, false)
         );
 
         // Then
@@ -189,7 +190,7 @@ public void should_not_delete_kafka_topic_using_admin_client_given_apply_delete_
         Collection<ChangeResult<TopicChange>> results = manager.update(
                 KafkaResourceManager.UpdateMode.APPLY,
                 objects,
-                KafkaResourceOperationContext.with(options, false)
+                KafkaResourceUpdateContext.with(options, false)
         );
 
         // Then
@@ -221,7 +222,7 @@ public void should_delete_kafka_topic_using_admin_client_given_apply_delete_orph
         Collection<ChangeResult<TopicChange>> results = manager.update(
                 KafkaResourceManager.UpdateMode.APPLY,
                 objects,
-                KafkaResourceOperationContext.with(options, false)
+                KafkaResourceUpdateContext.with(options, false)
         );
 
         // Then