OffsetCommitRequest constructor

OffsetCommitRequest(
  1. String consumerGroup,
  2. List<ConsumerOffset> offsets,
  3. int consumerGroupGenerationId,
  4. String consumerId,
  5. int retentionTime,
)

Creates new instance of OffsetCommitRequest.

host must be current coordinator broker for consumerGroup.

Implementation

OffsetCommitRequest(this.consumerGroup, this.offsets, this.consumerGroupGenerationId, this.consumerId, this.retentionTime) : super();