search

eventuate-foundation / eventuate-cdc

Other
73 stars 31 forks source link

field `published` in table message don't change after publish message #139

Closed rainbowechoes closed 1 year ago

rainbowechoes commented 1 year ago

Hi, everyone.

I use mysql binlog + kafka in cdc service to implement transactional messaging.

But I find field published in table message don't change after publish message. so if I restart cdc service again, it will send before message again.

I don't find code about update published filed in MySqlBinaryLogClient.

how should I make the sended message to be published?

cer commented 1 year ago

The published column is only used by PollingDao.

MySqlBinlog saves the current file/offset in a Kafka topic. When the CDC restarts after normal shutdown it should not republish messages.

rainbowechoes commented 1 year ago

Thanks for your reply!

I understand it.

Another question, I set logging.level.root=debug, then there is some error in console. like this:

image image image

cdc service works fine, but are there hidden problems if these errors are not handled?