CONFLUENT PLATFORM
The Replicator verifier is a command line tool for identifying issues with a Replicator configuration and recommending remedial actions. This tool accepts a connector or an executable configuration and runs a number of checks against the clusters referenced. This can be useful for:
Run the Replicator verifier using the configuration from three sources:
Note
Replicator verifier should be run from the same host that will run Replicator
From Replicator executable:
replicator-verifier \ --consumer.config ./consumer.properties \ --producer.config ./producer.properties \ --replication.config ./replication.properties
From a connector json:
replicator-verifier \ --replicator-json ./replicator.json
From a deployed connector:
replicator-verifier \ --connect-url localhost:8083 \ --connector-name replicator
On completion the Replicator verifier will produce a summary of checks performed and their results:
[2020-02-28 12:39:02,252] INFO All checks completed. (io.confluent.connect.replicator.Verifier) [2020-02-28 12:39:02,252] INFO Source cluster describe configs check : PASSED (io.confluent.connect.replicator.Verifier) [2020-02-28 12:39:02,253] INFO Connectivity check Destination : PASSED (io.confluent.connect.replicator.Verifier) [2020-02-28 12:39:02,253] INFO topic.whitelist/topic.blacklist check : PASSED (io.confluent.connect.replicator.Verifier) [2020-02-28 12:39:02,253] INFO License manager check : PASSED (io.confluent.connect.replicator.Verifier) [2020-02-28 12:39:02,253] INFO Consumer offset commit check source : PASSED (io.confluent.connect.replicator.Verifier) [2020-02-28 12:39:02,253] INFO Consumer offset commit check destination : PASSED (io.confluent.connect.replicator.Verifier) [2020-02-28 12:39:02,253] INFO Destination topic ACL check : PASSED (io.confluent.connect.replicator.Verifier) [2020-02-28 12:39:02,253] INFO Topic regex check : PASSED (io.confluent.connect.replicator.Verifier) [2020-02-28 12:39:02,253] INFO Source topic ACL check : PASSED (io.confluent.connect.replicator.Verifier) [2020-02-28 12:39:02,253] INFO Connectivity check Source : PASSED (io.confluent.connect.replicator.Verifier) [2020-02-28 12:39:02,253] INFO Verifier run complete. (io.confluent.connect.replicator.Verifier)
Any failed checks are accompanied by guidance explaining the relevant parameters to resolve the issue:
[2020-02-28 12:41:46,846] INFO License manager check : FAILED By default, Replicator will assume the license is stored in the _confluent-command topic on the destination cluster. Please ensure that the properties prefixed "dest.kafka." refer to your license cluster, topic and principal. Alternatively, these can be overridden using the "confluent.topic." prefix (e.g. confluent.topic.bootstrap.servers). (io.confluent.connect.replicator.Verifier)
Important
Replicator verifier does not currently support monitoring interceptors. Configurations like *.interceptor.classes should be removed from Replicator configurations before running the verifier.
The available command line parameters are:
--connect-url
--connector-name
--replicator-json
--producer.config
--consumer.config
--replication.config
--destination-test-topic
Replicator verifier performs the following checks to determine that the configuration provided is valid.
Intrusive checks will temporarily change the state of the cluster they are performed on. These changes take the form of topic creation/manipulation and consumer offset commits. Replicator verifier will prompt for approval before running these checks and as such should be run in interactive mode.