@Test
public void testConfigureWithNonSerializableCustomPartitionerFails() {

	exception.expect(IllegalArgumentException.class);
	exception.expectMessage("The provided custom partitioner is not serializable");
	new FlinkKinesisProducer<>(new SimpleStringSchema(), getStandardProperties())
		.setCustomPartitioner(new NonSerializableCustomPartitioner());
}