config/phobos.yml.example in phobos-1.8.2 vs config/phobos.yml.example in phobos-1.8.3.pre.beta1
- old
+ new
@@ -107,14 +107,11 @@
force_encoding:
# Specify the delivery method for a listener.
# Possible values: [`message`, `batch` (default)]
# - `message` will yield individual messages from Ruby Kafka using `each_message` and will commit/heartbeat at every consumed message.
# This is overall a bit slower than using batch, but easier to configure.
- # - `batch` will yield batches from Ruby Kafka using `each_batch`, and commit/heartbeat at every consumed batch.
- # Due to implementation in Ruby Kafka, it should be noted that when configuring large batch sizes in combination with taking long time to consume messages,
- # your consumers might get kicked from the Kafka cluster for not sending a heartbeat within the expected interval.
- # Take this into consideration when determining your configuration. You can send heartbeats manually while
- # processing your messages if necessary.
+ # - `batch` will yield batches from Ruby Kafka using `each_batch`, and commit at every consumed batch. It will
+ # still heartbeat after every message if necessary (using the heartbeat_interval, below).
# - `inline_batch` also uses `each_batch`, but will pass the entire batch to your handler instead
# of one message at a time. To use this method, you should include Phobos::BatchHandler
# instead of Phobos::Handler so that you can make use of the `consume_batch` etc. methods.
# Note: Ultimately commit/heartbeart will depend on the offset commit options and the heartbeat interval.
delivery: batch