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