KinesisSystemFactory implements SystemFactory { @Override public SystemConsumer getConsumer(String system, Config config, MetricsRegistry registry) { KinesisConfig kConfig = new KinesisConfig(config); return new KinesisSystemConsumer(system, kConfig, registry); }  @Override SystemConsumer getConsumer(String system, Config config, MetricsRegistry registry); @Override SystemProducer getProducer(String system, Config config, MetricsRegistry registry); @Override SystemAdmin getAdmin(String system, Config config);  }
@Test public void testGetConsumer() { String systemName = "test"; Config config = buildKinesisConsumerConfig(systemName); KinesisSystemFactory factory = new KinesisSystemFactory(); MetricsRegistry metricsRegistry = new NoOpMetricsRegistry(); Assert.assertNotSame(factory.getConsumer("test", config, metricsRegistry), factory.getAdmin(systemName, config)); }