mirus
mirus copied to clipboard
Mirus is a cross data-center data replication tool for Apache Kafka
Snyk has created this PR to fix one or more vulnerable packages in the `maven` dependencies of this project. #### Changes included in this PR - Changes to the following...
As a follow-up to https://github.com/salesforce/mirus/issues/73, just adding a note on the change from the default behavior.
Hello, I am evaluating different tools for data kafka replication. I've read awesome comments about Mirus tool so I've decided give it a try. Playing with that tool my scenario...
Snyk has created this PR to upgrade org.apache.kafka:connect-json from 2.6.2 to 2.8.1. :information_source: Keep your dependencies up-to-date. This makes it easier to fix existing vulnerabilities and to more quickly identify...
Snyk has created this PR to upgrade com.fasterxml.jackson.dataformat:jackson-dataformat-csv from 2.10.0 to 2.13.0. :information_source: Keep your dependencies up-to-date. This makes it easier to fix existing vulnerabilities and to more quickly identify...
Hi! This pull request was created by [OpenRewrite](https://github.com/openrewrite/rewrite), and successfully upgrades this project to JUnit 5. Hope it helps :) Co-authored-by: Moderne
By default Kafka Consumer has `auto.offset.reset` policy [configured to latest](https://kafka.apache.org/documentation/#consumerconfigs_auto.offset.reset). But it looks that the implementation in this connector is reverse -- unless it is configured it will start with...
Reset metrics when connector/task failed, this is to prevent Worker reporting the last task state metrics which could be obsolete. A better place to reset metrics is in connector/task's `stop`...
I'm new to Kafka and Mirus and have been experimenting with the quickstarts for both of them. It was pretty easy to get the default configuration going (hats off to...
The configuration of the source converter is not supported. I can't set `schema.enable = false` when I use `JsonConverter`. It also cannot set the `schema.registry.url` for `KafkaAvroDeserializer`. ``` { ......