pingcap / tiflow

This repo maintains DM (a data migration platform) and TiCDC (change data capture for TiDB)
Apache License 2.0
417 stars 272 forks source link

consumer do not panic if meet unusual kafka cluster error #11358

Closed 3AceShowHand closed 6 days ago

3AceShowHand commented 6 days ago

If the kafka cluster is unavailable temporarily, just retry it.