Note:
This topic has been translated from a Chinese forum by GPT and might contain errors.Original topic: ticdc 接入 kafka 后过一段时间报panic
Database version v5.4.0
Kafka version 1.1.1
Phenomenon: It restarts itself repeatedly after a period of time.
goroutine 30831 [running]:
github.com/pingcap/tiflow/cdc/sink/codec.rowEventToMaxwellMessage(0xc009428600, 0x3, 0x0)
github.com/pingcap/tiflow/cdc/sink/codec/maxwell.go:162 +0xf2d
github.com/pingcap/tiflow/cdc/sink/codec.(*MaxwellEventBatchEncoder).AppendRowChangedEvent(0xc004eb8ab0, 0xc009428600, 0x0, 0x0, 0x3)
github.com/pingcap/tiflow/cdc/sink/codec/maxwell.go:180 +0x2f
github.com/pingcap/tiflow/cdc/sink.(*mqSink).runWorker(0xc0016450e0, 0x40dc5a8, 0xc003e15280, 0xc000000000, 0x0, 0x0)
github.com/pingcap/tiflow/cdc/sink/mq.go:338 +0x3f1
github.com/pingcap/tiflow/cdc/sink.(*mqSink).run.func1(0x0, 0xc0012cb198)
github.com/pingcap/tiflow/cdc/sink/mq.go:267 +0x46
The Go Programming Language(0xc0072aac90, 0xc0040f4480)
golang.org/x/sync@v0.0.0-20210220032951-036812b2e83c/errgroup/errgroup.go:57 +0x59
created by The Go Programming Language
golang.org/x/sync@v0.0.0-20210220032951-036812b2e83c/errgroup/errgroup.go:54 +0x66
panic: interface conversion: interface {} is string, not uint8