Kafunk


OffsetRequest

Namespace: Kafunk
Parent Module: Protocol

A request to return offset information for a set of topics on a specific replica.

Record Fields

Record FieldDescription
replicaId
Signature: ReplicaId
topics
Signature: (TopicName * (Partition * Time * MaxNumberOfOffsets) []) []

Constructors

ConstructorDescription
new(replicaId, topics)
Signature: (replicaId:ReplicaId * topics:(TopicName * (Partition * Time * MaxNumberOfOffsets) []) []) -> OffsetRequest

CompiledName: .ctor

Fork me on GitHub