diff --git a/library/kafka_topic.py b/library/kafka_topic.py
index a6004b3..bc02532 100644
--- 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
index 3188b8e..754ca25 100644
--- 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'