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