search

salesforce / mirus

Mirus is a cross data-center data replication tool for Apache Kafka
BSD 3-Clause "New" or "Revised" License
203 stars 43 forks source link

ReplayPolicy.IGNORE does not process new records #87

Closed savinov closed 2 years ago

savinov commented 2 years ago

ReplayPolicy.IGNORE filters all the messages: duplicates and a new ones. The policy is set by default, so mirus just ignores all the messages from the source cluster, which is useless. See: https://github.com/salesforce/mirus/issues/65 https://github.com/salesforce/mirus/pull/64#discussion_r782907492 https://github.com/salesforce/mirus/blob/master/src/main/java/com/salesforce/mirus/MirusSourceTask.java#L256

pdavidson100 commented 2 years ago

Thanks for reporting @savinov . PR for a fix submitted here https://github.com/salesforce/mirus/pull/88

pdavidson100 commented 2 years ago

Fix merged. Closing issue.