ConsumerGroup constructor

ConsumerGroup(
  1. KafkaSession session,
  2. String name
)

Implementation

ConsumerGroup(this.session, this.name);