@Test
public void testConfigureWithSerializableCustomPartitioner() {

	new FlinkKinesisProducer<>(new SimpleStringSchema(), getStandardProperties())
		.setCustomPartitioner(new SerializableCustomPartitioner());
}