lib/manageiq/messaging/kafka/client.rb in manageiq-messaging-0.1.3 vs lib/manageiq/messaging/kafka/client.rb in manageiq-messaging-0.1.4

- old
+ new

@@ -24,12 +24,14 @@ # Kafka specific +publish_message+ options: # * :group_name (Used as Kafka partition_key) # # Kafka specific +subscribe_topic+ options: # * :persist_ref (Used as Kafka group_id) + # * :session_timeout (Max time in seconds allowed to process a message, default is 30) # # Kafka specific +subscribe_messages+ options: # * :max_bytes (Max batch size to read, default is 10Mb) + # * :session_timeout (Max time in seconds allowed to process a message, default is 30) # # 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