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