|
@@ -114,7 +114,7 @@ func (b *Broker) GetMetadata(clientID string, request *MetadataRequest) (*Metada
|
|
|
return response, nil
|
|
return response, nil
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-func (b *Broker) GetOffset(clientID string, request *OffsetRequest) (*OffsetResponse, error) {
|
|
|
|
|
|
|
+func (b *Broker) GetAvailableOffsets(clientID string, request *OffsetRequest) (*OffsetResponse, error) {
|
|
|
response := new(OffsetResponse)
|
|
response := new(OffsetResponse)
|
|
|
|
|
|
|
|
err := b.sendAndReceive(clientID, request, response)
|
|
err := b.sendAndReceive(clientID, request, response)
|