### Question:
KafkaPlugin implements Plugin { @Override public synchronized Iterable<ConnectorFactory> getConnectorFactories() { return ImmutableList.of(new KafkaConnectorFactory(extension)); } KafkaPlugin();  KafkaPlugin(Module extension); @Override synchronized Iterable<ConnectorFactory> getConnectorFactories(); static final Module DEFAULT_EXTENSION; }### Answer:
@Test public void testSpinup() { KafkaPlugin plugin = new KafkaPlugin(); ConnectorFactory factory = getOnlyElement(plugin.getConnectorFactories()); assertInstanceOf(factory, KafkaConnectorFactory.class); Connector c = factory.create( "test-connector", ImmutableMap.<String, String>builder() .put("kafka.table-names", "test") .put("kafka.nodes", "localhost:9092") .build(), new TestingConnectorContext()); assertNotNull(c); }