From 46548206901a4b8ad77aeec35e193fb33217e789 Mon Sep 17 00:00:00 2001 From: Carlos Henrique Date: Fri, 21 Dec 2018 09:40:31 -0200 Subject: [PATCH] Fix typo error --- lib/kafka_ex.ex | 2 +- lib/kafka_ex/gen_consumer.ex | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/kafka_ex.ex b/lib/kafka_ex.ex index 9f97fbc1..9b6120d6 100644 --- a/lib/kafka_ex.ex +++ b/lib/kafka_ex.ex @@ -540,7 +540,7 @@ defmodule KafkaEx do Merges the given options with defaults from the application env config. Returns `{:error, :invalid_consumer_options}` if the consumer group - configuation is invalid, and `{:ok, merged_options}` otherwise. + configuration is invalid, and `{:ok, merged_options}` otherwise. Note this happens automatically when using `KafkaEx.create_worker`. """ diff --git a/lib/kafka_ex/gen_consumer.ex b/lib/kafka_ex/gen_consumer.ex index 6e04a2de..9dcd4263 100644 --- a/lib/kafka_ex/gen_consumer.ex +++ b/lib/kafka_ex/gen_consumer.ex @@ -52,7 +52,7 @@ defmodule KafkaEx.GenConsumer do ## Committing Offsets - `KafkaEx.GenConsumer` manages a consumer's offsets by committing the the offsets + `KafkaEx.GenConsumer` manages a consumer's offsets by committing the offsets of consumed messages. KafkaEx supports two commit strategies: asynchronous and synchronous. The return value of `c:handle_message_set/2` determines which strategy is used: