KinesisSystemFactory implements SystemFactory { @Override public SystemAdmin getAdmin(String system, Config config) { validateConfig(system, config); KinesisConfig kConfig = new KinesisConfig(config); return new KinesisSystemAdmin(system, kConfig); }  @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);  }
@Ignore @Test(expected = ConfigException.class) public void testGetAdminWithIncorrectSspGrouper() { String systemName = "test"; KinesisSystemFactory factory = new KinesisSystemFactory(); Config config = buildKinesisConsumerConfig(systemName, "org.apache.samza.container.grouper.stream.SystemStreamPartitionGrouperFactory"); factory.getAdmin(systemName, config); }
@Ignore @Test(expected = ConfigException.class) public void testGetAdminWithBroadcastStreams() { String systemName = "test"; KinesisSystemFactory factory = new KinesisSystemFactory(); Config config = buildKinesisConsumerConfig(systemName, "org.apache.samza.container.grouper.stream.AllSspToSingleTaskGrouperFactory", "test.stream#0"); factory.getAdmin(systemName, config); }
@Ignore @Test(expected = ConfigException.class) public void testGetAdminWithBootstrapStream() { String systemName = "test"; KinesisSystemFactory factory = new KinesisSystemFactory(); Config config = buildKinesisConsumerConfig(systemName, "org.apache.samza.container.grouper.stream.AllSspToSingleTaskGrouperFactory", null, "kinesis-stream" ); factory.getAdmin(systemName, config); }