Details
-
Improvement
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
Description
Currently, MirrorMaker is started using `
./bin/connect-mirror-maker.sh mm2.properties` shell command. However, even if the shell command has exited and a log with `Kafka MirrorMaker started` has been printed, it is likely that the underlying connectors and tasks have not been configured.
This tasks aims to make the MirrorMaker startup synchronous by either waiting for connections & tasks to move to running state before exiting the `MirrorMaker#start()` function or by blocking completion of `main()`.
A conversation about this was done in https://github.com/apache/kafka/pull/13284