数据库版本 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