change comment of requestOffsets

childe · Oct 14, 2024 · 89ffa1c · 89ffa1c
1 parent 2f8753a
commit 89ffa1c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/broker.go b/broker.go
@@ -356,7 +356,7 @@ func (broker *Broker) requestMetaData(clientID string, topics []string) (r Metad
 	return r, err
 }
 
-// RequestOffsets return the offset values array from ther broker. all partitionID in partitionIDs must be in THIS broker
+// RequestOffsets return the offset from ther broker. all partitionID in partitionIDs must be in THIS broker
 func (broker *Broker) requestOffsets(clientID, topic string, partitionIDs []int32, timeValue int64, offsets uint32) (r OffsetsResponse, err error) {
 	offsetsRequest := NewOffsetsRequest(topic, partitionIDs, timeValue, offsets, clientID)