Commit dbae65d
committed
RHINENG-21276: replace kafka-go with patched version
fixing
panic: markRead: negative count
goroutine 227 [running]:
github.com/segmentio/kafka-go.(*messageSetReader).markRead(0xc001880440?)
/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.49/message_reader.go:353 +0x9e
github.com/segmentio/kafka-go.(*messageSetReader).readMessageV2(0xc001880440, 0x2?, 0xc001709b48, 0xc001709b38)
/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.49/message_reader.go:337 +0x6c8
github.com/segmentio/kafka-go.(*messageSetReader).readMessage(0xc001880440, 0x2d4def6, 0xc001709b48, 0xc001709b38)
/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.49/message_reader.go:138 +0x8e
github.com/segmentio/kafka-go.(*Batch).readMessage(0xc001fc1780, 0x0?, 0x0?)
/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.49/batch.go:248 +0x45
github.com/segmentio/kafka-go.(*Batch).ReadMessage(0xc001fc1780)
/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.49/batch.go:200 +0xe61 parent 9529066 commit dbae65d
2 files changed
Lines changed: 3 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
138 | 138 | | |
139 | 139 | | |
140 | 140 | | |
| 141 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
6 | 6 | | |
7 | 7 | | |
8 | 8 | | |
| 9 | + | |
| 10 | + | |
9 | 11 | | |
10 | 12 | | |
11 | 13 | | |
| |||
0 commit comments