config/phobos.yml.example in phobos-1.8.1 vs config/phobos.yml.example in phobos-1.8.2.pre.beta1

- old
+ new

@@ -105,10 +105,14 @@ # - `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. + # Take this into consideration when determining your configuration. You can send heartbeats manually while + # processing your messages if necessary. + # - `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 # Use this if custom backoff is required for a listener backoff: min_ms: 500