Decode also replica ID

offset_request.go

@@ -67,10 +67,14 @@ func (r *OffsetRequest) encode(pe packetEncoder) error {
 func (r *OffsetRequest) decode(pd packetDecoder, version int16) error {
 	r.Version = version
 
-	// Ignore replica ID
+	replicaID, err := pd.getInt32()
-	if _, err := pd.getInt32(); err != nil {
+	if err != nil {
 		return err
 	}
+	if replicaID >= 0 {
+		r.SetReplicaID(replicaID)
+	}
+
 	blockCount, err := pd.getArrayLength()
 	if err != nil {
 		return err

offset_request_test.go

@@ -49,5 +49,5 @@ func TestOffsetRequestV1(t *testing.T) {
 func TestOffsetRequestReplicaID(t *testing.T) {
 	request := new(OffsetRequest)
 	request.SetReplicaID(42)
-	testRequestEncode(t, "with replica ID", request, offsetRequestReplicaID)
+	testRequest(t, "with replica ID", request, offsetRequestReplicaID)
 }