ticdc 接入 kafka 后过一段时间报panic

数据库版本 v5.4.0

kafka 版本 1.1.1

现象,过段时间就自己反复重启

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 golang.org/x/sync/errgroup.(*Group).Go.func1(0xc0072aac90, 0xc0040f4480) golang.org/x/sync@v0.0.0-20210220032951-036812b2e83c/errgroup/errgroup.go:57 +0x59 created by golang.org/x/sync/errgroup.(*Group).Go golang.org/x/sync@v0.0.0-20210220032951-036812b2e83c/errgroup/errgroup.go:54 +0x66 panic: interface conversion: interface {} is string, not []uint8

你看看是不是https://github.com/pingcap/tiflow/issues/2758这个问题

我关注过这个问题,asktug里也有人遇到过,不过我看在 5.2 版本以后就fix了,我这个版本是 5.4.0,难道还没有修复吗?

如果可以建议升级到最新的版本试一下

该主题在最后一个回复创建后60天后自动关闭。不再允许新的回复。