Add a getter for replica ID

IBM · Oct 25, 2018 · 1900f52 · 1900f52
1 parent 9dd879a
commit 1900f52
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/offset_request.go b/offset_request.go
@@ -130,6 +130,13 @@ func (r *OffsetRequest) SetReplicaID(id int32) {
 	r.replicaID = &r.storeReplicaID
 }
 
+func (r *OffsetRequest) ReplicaID() int32 {
+	if r.replicaID == nil {
+		return -1
+	}
+	return r.storeReplicaID
+}
+
 func (r *OffsetRequest) AddBlock(topic string, partitionID int32, time int64, maxOffsets int32) {
 	if r.blocks == nil {
 		r.blocks = make(map[string]map[int32]*offsetRequestBlock)