Merge pull request #897 from abicky/fix-yard-annotation

Fix "@param tag has unknown parameter name"

Author: dasch

lib/kafka/cluster.rb

@@ -120,7 +120,7 @@ def get_leader(topic, partition)
 
     # Finds the broker acting as the coordinator of the given group.
     #
-    # @param group_id: [String]
+    # @param group_id [String]
     # @return [Broker] the broker that's currently coordinator.
     def get_group_coordinator(group_id:)
       @logger.debug "Getting group coordinator for `#{group_id}`"
@@ -130,7 +130,7 @@ def get_group_coordinator(group_id:)
 
     # Finds the broker acting as the coordinator of the given transaction.
     #
-    # @param transactional_id: [String]
+    # @param transactional_id [String]
     # @return [Broker] the broker that's currently coordinator.
     def get_transaction_coordinator(transactional_id:)
       @logger.debug "Getting transaction coordinator for `#{transactional_id}`"

lib/kafka/protocol/encoder.rb

@@ -126,7 +126,7 @@ def write_varint_string(string)
       # Writes an integer under varints serializing to the IO object.
       # https://developers.google.com/protocol-buffers/docs/encoding#varints
       #
-      # @param string [Integer]
+      # @param int [Integer]
       # @return [nil]
       def write_varint(int)
         int = int << 1