Correct the docs

dasch · dasch · commit e6a77808dcc0 · 2018-02-21T10:16:34.000+01:00
diff --git a/lib/kafka/client.rb b/lib/kafka/client.rb
@@ -405,10 +405,7 @@ def fetch_messages(topic:, partition:, offset: :latest, max_wait_time: 5, min_by
     # @param topic [String] the topic to consume messages from.
     #
     # @param start_from_beginning [Boolean] whether to start from the beginning
-    #   of the topic or just subscribe to new messages being produced. This
-    #   only applies when first consuming a topic partition – once the consumer
-    #   has checkpointed its progress, it will always resume from the last
-    #   checkpoint.
+    #   of the topic or just subscribe to new messages being produced.
     #
     # @param max_wait_time [Integer] the maximum amount of time to wait before
     #   the server responds, in seconds.

Original file line number	Diff line number	Diff line change
`@@ -405,10 +405,7 @@ def fetch_messages(topic:, partition:, offset: :latest, max_wait_time: 5, min_by`
`405`	`405`	`# @param topic [String] the topic to consume messages from.`
`406`	`406`	`#`
`407`	`407`	`# @param start_from_beginning [Boolean] whether to start from the beginning`
`408`		`- # of the topic or just subscribe to new messages being produced. This`
`409`		`- # only applies when first consuming a topic partition – once the consumer`
`410`		`- # has checkpointed its progress, it will always resume from the last`
`411`		`- # checkpoint.`
	`408`	`+ # of the topic or just subscribe to new messages being produced.`
`412`	`409`	`#`
`413`	`410`	`# @param max_wait_time [Integer] the maximum amount of time to wait before`
`414`	`411`	`# the server responds, in seconds.`