go 1.0 compatibility; all we lose is ipv6 zones

broker.go

@@ -49,7 +49,7 @@ func (b *Broker) Connect() error {
 		return err
 	}
 
-	b.conn, err = net.DialTCP("tcp", nil, &net.TCPAddr{IP: addr.IP, Port: int(b.port), Zone: addr.Zone})
+	b.conn, err = net.DialTCP("tcp", nil, &net.TCPAddr{IP: addr.IP, Port: int(b.port)})
 	if err != nil {
 		return err
 	}
@@ -226,6 +226,8 @@ func (b *Broker) sendAndReceive(clientID string, req requestEncoder, res decoder
 	case err = <-promise.errors:
 		return err
 	}
+
+	return nil
 }
 
 func (b *Broker) decode(pd packetDecoder) (err error) {

consumer.go

@@ -80,6 +80,8 @@ func (c *Consumer) sendError(err error) bool {
 	case c.errors <- err:
 		return true
 	}
+
+	return true
 }
 
 func (c *Consumer) fetchMessages() {

errors.go

@@ -89,7 +89,7 @@ func (err KError) Error() string {
 		return "kafka server: Stale controller epoch code. ???"
 	case OFFSET_METADATA_TOO_LARGE:
 		return "kafka server: Specified a string larger than the configured maximum for offset metadata."
-	default:
-		return "Unknown error, how did this happen?"
 	}
+
+	return "Unknown error, how did this happen?"
 }

producer.go

@@ -110,7 +110,7 @@ func (p *Producer) safeSendMessage(key, value Encoder, retry bool) error {
 			return err
 		}
 		return p.safeSendMessage(key, value, false)
-	default:
-		return block.Err
 	}
+
+	return block.Err
 }

real_decoder.go

@@ -90,11 +90,11 @@ func (rd *realDecoder) getBytes() ([]byte, error) {
 	case n > rd.remaining():
 		rd.off = len(rd.raw)
 		return nil, InsufficientData
-	default:
-		tmp := rd.raw[rd.off : rd.off+n]
-		rd.off += n
-		return tmp, nil
 	}
+
+	tmpStr := rd.raw[rd.off : rd.off+n]
+	rd.off += n
+	return tmpStr, nil
 }
 
 func (rd *realDecoder) getString() (string, error) {
@@ -116,11 +116,11 @@ func (rd *realDecoder) getString() (string, error) {
 	case n > rd.remaining():
 		rd.off = len(rd.raw)
 		return "", InsufficientData
-	default:
-		tmp := string(rd.raw[rd.off : rd.off+n])
-		rd.off += n
-		return tmp, nil
 	}
+
+	tmpStr := string(rd.raw[rd.off : rd.off+n])
+	rd.off += n
+	return tmpStr, nil
 }
 
 func (rd *realDecoder) getInt32Array() ([]int32, error) {