Fix ignored errors

iobeam · Apr 22, 2016 · fd30733 · fd30733
1 parent dfcc855
commit fd30733
Showing 1 changed file with 12 additions and 3 deletions.
diff --git a/avro_encoder_decoder.go b/avro_encoder_decoder.go
@@ -76,10 +76,16 @@ func (this *KafkaAvroEncoder) Encode(obj interface{}) ([]byte, error) {
 	}
 
 	buffer := &bytes.Buffer{}
-	buffer.Write(magic_bytes)
+	_, err = buffer.Write(magic_bytes)
+	if err != nil {
+		return nil, err
+	}
 	idSlice := make([]byte, 4)
 	binary.BigEndian.PutUint32(idSlice, uint32(id))
-	buffer.Write(idSlice)
+	_, err = buffer.Write(idSlice)
+	if err != nil {
+		return nil, err
+	}
 
 	enc := avro.NewBinaryEncoder(buffer)
 	var writer avro.DatumWriter
@@ -89,7 +95,10 @@ func (this *KafkaAvroEncoder) Encode(obj interface{}) ([]byte, error) {
 		writer = avro.NewSpecificDatumWriter()
 	}
 	writer.SetSchema(schema)
-	writer.Write(obj, enc)
+	err = writer.Write(obj, enc)
+	if err != nil {
+		return nil, err
+	}
 
 	return buffer.Bytes(), nil
 }