phobos.yml.example in phobos-1.1.0

- old
+ new

@@ -43,10 +43,18 @@
   # Valid codecs: `:snappy` and `:gzip`
   compression_codec:
   # number of messages that needs to be in a message set before it should be compressed.
   # Note that message sets are per-partition rather than per-topic or per-producer
   compression_threshold: 1
+  # maximum number of messages allowed in the queue. Only used for async_producer
+  max_queue_size: 1000
+  # if greater than zero, the number of buffered messages that will automatically
+  # trigger a delivery. Only used for async_producer
+  delivery_threshold: 0
+  # if greater than zero, the number of seconds between automatic message
+  # deliveries. Only used for async_producer
+  delivery_interval: 0
 
 consumer:
   # number of seconds after which, if a client hasn't contacted the Kafka cluster,
   # it will be kicked out of the group
   session_timeout: 30
@@ -65,14 +73,21 @@
 listeners:
   - handler: Phobos::EchoHandler
     topic: test
     # id of the group that the consumer should join
     group_id: test-1
+    # Number of threads created for this listener, each thread will behave as an independent consumer.
+    # They don't share any state
+    max_concurrency: 1
     # Once the consumer group has checkpointed its progress in the topic's partitions,
     # the consumers will always start from the checkpointed offsets, regardless of config
     # As such, this setting only applies when the consumer initially starts consuming from a topic
     start_from_beginning: true
     # maximum amount of data fetched from a single partition at a time
     max_bytes_per_partition: 524288 # 512 KB
-    # Number of threads created for this listener, each thread will behave as an independent consumer.
-    # They don't share any state
-    max_concurrency: 1
+    # Minimum number of bytes to read before returning messages from the server; if `max_wait_time` is reached, this is ignored.
+    min_bytes: 1
+    # Maximum duration of time to wait before returning messages from the server, in seconds
+    max_wait_time: 5
+    # Apply this encoding to the message payload, if blank it uses the original encoding. This property accepts values
+    # defined by the ruby Encoding class (https://ruby-doc.org/core-2.3.0/Encoding.html). Ex: UTF_8, ASCII_8BIT, etc
+    force_encoding: