Skip to content

Commit 6345128

Browse files
Update comments
Co-authored-by: Jeroen de Bruijn <[email protected]>
1 parent dd7550f commit 6345128

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

lib/kafka-consumer.js

+2-2
Original file line numberDiff line numberDiff line change
@@ -364,8 +364,8 @@ KafkaConsumer.prototype.unsubscribe = function() {
364364
* Read a number of messages from a specific topic and partition.
365365
*
366366
* Can be useful if the consume performance differs per partition. Consuming
367-
* per partition could prevent slow performance on one partition to effect the
368-
* consumption of other partitions.
367+
* per partition could prevent slow performance on one partition from affecting
368+
* the consumption of other partitions.
369369
*
370370
* To select the right partition it is required to set a topic param, because a
371371
* consumer can be subscribed to multiple topics.

src/workers.cc

+1-1
Original file line numberDiff line numberDiff line change
@@ -783,7 +783,7 @@ void KafkaConsumerConsumeLoop::HandleErrorCallback() {
783783
}
784784

785785
/**
786-
* @brief KafkaConsumer get messages worker.
786+
* @brief KafkaConsumer get messages per partition worker.
787787
*
788788
* This callback will get a number of messages from a specific partition.
789789
* Can be of use in streams or places where you don't want an infinite

0 commit comments

Comments
 (0)