wip

IBM · Jun 9, 2015 · a067a18 · a067a18
1 parent 377669e
commit a067a18
Show file tree

Hide file tree

Showing 2 changed files with 398 additions and 0 deletions.
diff --git a/offset_fetch_response.go b/offset_fetch_response.go
@@ -80,3 +80,15 @@ func (r *OffsetFetchResponse) decode(pd packetDecoder) (err error) {
 
 	return nil
 }
+
+func (r *OffsetFetchResponse) GetBlock(topic string, partition int32) *OffsetFetchResponseBlock {
+	if r.Blocks == nil {
+		return nil
+	}
+
+	if r.Blocks[topic] == nil {
+		return nil
+	}
+
+	return r.Blocks[topic][partition]
+}