diff --git a/lib/kafka/cluster.rb b/lib/kafka/cluster.rb
index bc3717e8..98c813bb 100644
--- a/lib/kafka/cluster.rb
+++ b/lib/kafka/cluster.rb
@@ -117,7 +117,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}`"
@@ -127,7 +127,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}`"
diff --git a/lib/kafka/protocol/encoder.rb b/lib/kafka/protocol/encoder.rb
index d4bc7a39..56a584a0 100644
--- a/lib/kafka/protocol/encoder.rb
+++ b/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