lib/manageiq/messaging/kafka/client.rb in manageiq-messaging-0.1.1 vs lib/manageiq/messaging/kafka/client.rb in manageiq-messaging-0.1.2
- old
+ new
@@ -25,9 +25,12 @@
# * :group_name (Used as Kafka partition_key)
#
# Kafka specific +subscribe_topic+ options:
# * :persist_ref (Used as Kafka group_id)
#
+ # Kafka specific +subscribe_messages+ options:
+ # * :max_bytes (Max batch size to read, default is 10Mb)
+ #
# Without +:persist_ref+ every topic subscriber receives a copy of each message
# only when they are active. If multiple topic subscribers join with the same
# +:persist_ref+, each message is consumed by only one of the subscribers. This
# allows a load balancing among the subscribers. Also any messages sent when
# all members of the +:persist_ref+ group are offline will be persisted and delivered