search

dyrnq / docker-canal

docker-canal
https://github.com/alibaba/canal
0 stars 0 forks source link

understanding canal.mq.partition and canal.mq.partitionsNum #36

Open dyrnq opened 4 weeks ago

dyrnq commented 4 weeks ago 
canal.mq.partition=0
# hash partition config
#canal.mq.partitionsNum=3
#canal.mq.partitionHash=test.table:id^name,.*\\..*
dyrnq commented 4 weeks ago

The canal.mq.partition parameter actually indicates the default partition to be written when canal.mq.partitionsNum and canal.mq.partitionHash are not set.

That means they can't coexist.

xref canal无法写入kafka多分区