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