Kafunk


OffsetCommitRequest

Namespace: Kafunk
Parent Module: Protocol

Record Fields

Record FieldDescription
consumerGroup
Signature: ConsumerGroup
consumerGroupGenerationId
Signature: ConsumerGroupGenerationId
consumerId
Signature: ConsumerId
retentionTime
Signature: RetentionTime
topics
Signature: (TopicName * (Partition * Offset * Timestamp * Meta) []) []

Constructors

ConstructorDescription
new(...)
Signature: (consumerGroup:ConsumerGroup * consumerGroupGenerationId:ConsumerGroupGenerationId * consumerId:ConsumerId * retentionTime:RetentionTime * topics:(TopicName * (Partition * Offset * Timestamp * Meta) []) []) -> OffsetCommitRequest

CompiledName: .ctor

Fork me on GitHub