Fix bug where we were waiting for a response when we shouldn't have been

protocol/broker.go

@@ -128,12 +128,15 @@ func (b *Broker) GetAvailableOffsets(clientID string, request *OffsetRequest) (*
 
 func (b *Broker) Produce(clientID string, request *ProduceRequest) (*ProduceResponse, error) {
 	var response *ProduceResponse
-	if request.ResponseCondition != NO_RESPONSE {
+	var err error
+
+	if request.ResponseCondition == NO_RESPONSE {
+		err = b.sendAndReceive(clientID, request, nil)
+	} else {
 		response = new(ProduceResponse)
+		err = b.sendAndReceive(clientID, request, response)
 	}
 
-	err := b.sendAndReceive(clientID, request, response)
-
 	if err != nil {
 		return nil, err
 	}