@Test
public void testCustomizedThreadPoolSizeInProducerConfiguration() {

	Properties testConfig = new Properties();
	testConfig.setProperty(AWSConfigConstants.AWS_REGION, "us-east-1");
	testConfig.setProperty(KinesisConfigUtil.THREAD_POOL_SIZE, "12");
	KinesisProducerConfiguration kpc = KinesisConfigUtil.getValidatedProducerConfiguration(testConfig);
	assertEquals(12, kpc.getThreadPoolSize());
}