Struct InvalidMessage

consumer.go:130–134

InvalidMessage is definition of invalid message used as argument for InvalidMessageCallback by Consumer.

	Logger:                           noopLogger,
}

// InvalidMessageCallback defines what should happen to messages which are identified as invalid.
// Such messages usually have missing or malformed required fields.
type InvalidMessageCallback func(ctx context.Context, msg InvalidMessage, err error)

// InvalidMessage is definition of invalid message used as argument for InvalidMessageCallback by Consumer.
type InvalidMessage struct {
	ID       string