fix tests

SystemCraftsman · Oct 23, 2020 · afee1b4 · afee1b4
1 parent e79227b
commit afee1b4
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 9 deletions.
diff --git a/tests/files/yaml/kafka-ephemeral.yaml b/tests/files/yaml/kafka-ephemeral.yaml
@@ -4,16 +4,22 @@ metadata:
   name: my-cluster
 spec:
   kafka:
-    version: 2.5.0
+    version: 2.6.0
     replicas: 3
     listeners:
-      plain: {}
-      tls: {}
+      - name: plain
+        port: 9092
+        type: internal
+        tls: false
+      - name: tls
+        port: 9093
+        type: internal
+        tls: true
     config:
       offsets.topic.replication.factor: 3
       transaction.state.log.replication.factor: 3
       transaction.state.log.min.isr: 2
-      log.message.format.version: "2.5"
+      log.message.format.version: "2.6"
     storage:
       type: ephemeral
   zookeeper:

diff --git a/tests/files/yaml/kafka-ephemeral_with_one_config.yaml b/tests/files/yaml/kafka-ephemeral_with_one_config.yaml
@@ -8,18 +8,24 @@ spec:
     userOperator: {}
   kafka:
     config:
-      log.message.format.version: '2.5'
+      log.message.format.version: '2.6'
       offsets.topic.replication.factor: 3
       transaction.state.log.min.isr: 2
       transaction.state.log.replication.factor: 3
       unclean.leader.election.enable: true
     listeners:
-      plain: {}
-      tls: {}
+    - name: plain
+      port: 9092
+      tls: false
+      type: internal
+    - name: tls
+      port: 9093
+      tls: true
+      type: internal
     replicas: 3
     storage:
       type: ephemeral
-    version: 2.5.0
+    version: 2.6.0
   zookeeper:
     replicas: 3
     storage:

diff --git a/tests/test_operator_command.py b/tests/test_operator_command.py
@@ -10,7 +10,7 @@ def setUp(self):
         self.runner = CliRunner()
         self.cluster = "my-cluster"
         self.namespace = "kafka"
-        self.installation_file_count = 22
+        self.installation_file_count = 23
 
     @mock.patch('kfk.operator_command.os.system')
     def test_install_strimzi(self, mock_os_system):