Skip to content
This repository was archived by the owner on Oct 7, 2022. It is now read-only.

Commit ccdb260

Browse files
committed
fix(ErrNilMessage.go): adjust errors structure
1 parent b6af16a commit ccdb260

File tree

2 files changed

+3
-5
lines changed

2 files changed

+3
-5
lines changed

src/errors/ErrNilMessage.go

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,5 @@
11
package errors
22

3-
type ErrNilMessage struct {}
3+
import "errors"
44

5-
func (err *ErrNilMessage) Error() string {
6-
return "message value is nil"
7-
}
5+
var ErrNilMessage = errors.New("message value is nil")

src/kafka/encode_decode.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ func (d *Decoder) DeserializerFor(recordType string) DecodeMessageFunc {
4040

4141
func (d *Decoder) AvroMessageToRecord(context context.Context, msg *sarama.ConsumerMessage) (*models.Record, error) {
4242
if msg.Value == nil {
43-
return nil, new(e.ErrNilMessage)
43+
return nil, e.ErrNilMessage
4444
}
4545

4646
schemaId := getSchemaId(msg)

0 commit comments

Comments
 (0)