Remove use of deprecated kafka_lib module in EXAMPLES

StephenSorriaux · Apr 13, 2024 · edf73b0 · edf73b0
1 parent fa71433
commit edf73b0
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 11 deletions.
diff --git a/library/kafka_topic.py b/library/kafka_topic.py
@@ -142,8 +142,7 @@
     # creates a topic 'test' with provided configuation for plaintext
     # configured Kafka and Zookeeper
     - name: create topic
-      kafka_lib:
-        resource: 'topic'
+      kafka_topic:
         api_version: "1.0.1"
         name: 'test'
         partitions: 2
@@ -160,8 +159,7 @@
 
     # creates a topic for a sasl_ssl configured Kafka and plaintext Zookeeper
     - name: create topic
-      kafka_lib:
-        resource: 'topic'
+      kafka_topic:
         api_version: "1.0.1"
         name: 'test'
         partitions: 2
@@ -183,8 +181,7 @@
     # creates a topic for a plaintext configured Kafka and a digest
     # authentication Zookeeper
     - name: create topic
-      kafka_lib:
-        resource: 'topic'
+      kafka_topic:
         api_version: "1.0.1"
         name: 'test'
         partitions: 2
@@ -203,8 +200,7 @@
 
     # deletes a topic
     - name: delete topic
-      kafka_lib:
-        resource: 'topic'
+      kafka_topic:
         api_version: "1.0.1"
         name: 'test'
         state: 'absent'
@@ -216,8 +212,7 @@
 
     # deletes a topic using automatic api_version discovery
     - name: delete topic
-      kafka_lib:
-        resource: 'topic'
+      kafka_topic:
         name: 'test'
         state: 'absent'
         zookeeper: >

diff --git a/library/kafka_topics.py b/library/kafka_topics.py
@@ -134,7 +134,7 @@
 
     # deletes a topic
     - name: delete topic
-      kafka_lib:
+      kafka_topics:
         topics:
         - name: 'test'
           state: 'absent'