升级到 debezium v2

相比dev-env里面给的设置，还需要额外的三个设置

      - "debezium.source.schema.history.internal.kafka.topic=debezium.history"
      - "debezium.source.schema.history.internal.kafka.bootstrap.servers=kafka:9092"
      - "debezium.source.topic.prefix=debezium"

debezium.source.topic.prefix 是强制的，所以也需要修改在kafak中对应的topic

server/internal/canal/canal.go

Lines 88 to 91 in 8f0b39e

    
           topics := []string{ 
        
           	"chii.bangumi.chii_subject_fields", 
        
           	"chii.bangumi.chii_subjects", 
        
           	"chii.bangumi.chii_members",

（这里应该改成可设置的，然后在 config.yaml 中进行设置）

不是很确定 debezium v2 写到 kafka 的数据格式有没有变化

	topics := []string{
	"chii.bangumi.chii_subject_fields",
	"chii.bangumi.chii_subjects",
	"chii.bangumi.chii_members",