MCPcopy
hub / github.com/segmentio/kafka-go / messageTooLarge

Function messageTooLarge

error.go:649–657  ·  view source on GitHub ↗
(msgs []Message, i int)

Source from the content-addressed store, hash-verified

647}
648
649func messageTooLarge(msgs []Message, i int) MessageTooLargeError {
650 remain := make([]Message, 0, len(msgs)-1)
651 remain = append(remain, msgs[:i]...)
652 remain = append(remain, msgs[i+1:]...)
653 return MessageTooLargeError{
654 Message: msgs[i],
655 Remaining: remain,
656 }
657}
658
659func (e MessageTooLargeError) Error() string {
660 return MessageSizeTooLarge.Error()

Callers 2

TestErrorFunction · 0.85
WriteMessagesMethod · 0.85

Calls

no outgoing calls

Tested by 1

TestErrorFunction · 0.68