Method: Kafka::Protocol::ConsumerGroupProtocol#initialize
- Defined in:
- lib/kafka/protocol/consumer_group_protocol.rb
#initialize(version: 0, topics:, user_data: nil) ⇒ ConsumerGroupProtocol
Returns a new instance of ConsumerGroupProtocol.
6 7 8 9 10 |
# File 'lib/kafka/protocol/consumer_group_protocol.rb', line 6 def initialize(version: 0, topics:, user_data: nil) @version = version @topics = topics @user_data = user_data end |