class KinesisPlugin implements Plugin {

    @Override
    public synchronized Iterable<ConnectorFactory> getConnectorFactories()
    {
        if (factory == null) {
            this.factory = new KinesisConnectorFactory();
        }
        return ImmutableList.of(this.factory);
    }

    public  KinesisPlugin();
    public  KinesisPlugin(KinesisConnectorFactory factory);

}