Hi colleagues,
I tried to find the answer in the mail list archive and the Internet, but found
nothing.
I see that kafka project doesn't introduce general extension/ plugin API for
three major releases.
I mean the top-level plugin/extension that allow to add some user-specific code
at the broker server.
e.g.:
trait Plugin {
def startup(server : Server) : Unit
def shutdown() : Unit
}
and load plugins by ServiceLoader at the `Kafka.main` after server start.
Does this approach conflict with kafka design? There are projects that have
been forced to fork the main class `Kafka` in order to implement this
functionality.
--
With best regards,
Taras Ledkov
