Merge pull request #485 from zendesk/dasch/refactor-create-topic

Improve the topic creation API

Author: dasch

lib/kafka/client.rb

@@ -451,8 +451,18 @@ def each_message(topic:, start_from_beginning: true, max_wait_time: 5, min_bytes
       end
     end
 
-    def create_topic(name, **options)
-      @cluster.create_topic(name, **options)
+    # Creates a topic in the cluster.
+    #
+    # @param name [String] the name of the topic.
+    # @param num_partitions [Integer] the number of partitions that should be created
+    #   in the topic.
+    # @param replication_factor [Integer] the replication factor of the topic.
+    # @param timeout [Integer] a duration of time to wait for the topic to be
+    #   completely created.
+    # @raise [Kafka::TopicAlreadyExists] if the topic already exists.
+    # @return [nil]
+    def create_topic(name, num_partitions: 1, replication_factor: 1, timeout: 30)
+      @cluster.create_topic(name, num_partitions: num_partitions, replication_factor: replication_factor, timeout: timeout)
     end
 
     # Lists all topics in the cluster.

lib/kafka/cluster.rb

@@ -145,7 +145,7 @@ def partitions_for(topic)
       raise
     end
 
-    def create_topic(name, num_partitions: 1, replication_factor: 1, timeout: 30)
+    def create_topic(name, num_partitions:, replication_factor:, timeout:)
       options = {
         topics: {
           name => {