Fix FindCoordinatorResponse.encode to allow nil Coordinator

IBM · Feb 14, 2018 · 20e9b58 · 20e9b58
1 parent 851e809
commit 20e9b58
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/find_coordinator_response.go b/find_coordinator_response.go
@@ -60,10 +60,22 @@ func (f *FindCoordinatorResponse) encode(pe packetEncoder) error {
 		}
 	}
 
+	if f.Coordinator == nil {
+		pe.putInt32(0)
+		if err := pe.putString(""); err != nil {
+			return nil
+		}
+		pe.putInt32(0)
+		if f.Version >= 1 {
+			if err := pe.putNullableString(nil); err != nil {
+				return nil
+			}
+		}
+		return nil
+	}
 	if err := f.Coordinator.encode(pe, 0); err != nil {
 		return err
 	}
-
 	return nil
 }