class KafkaPlugin implements Plugin {

    @Override
    public synchronized Iterable<ConnectorFactory> getConnectorFactories()
    {
        return ImmutableList.of(new KafkaConnectorFactory(extension));
    }

    public  KafkaPlugin();
    public  KafkaPlugin(Module extension);

}