@Test
public void testConfigureOnCheckpointsCommitMode() throws Exception {

	@SuppressWarnings("unchecked")
	// auto-commit enabled; this should be ignored in this case
	final DummyFlinkKafkaConsumer<String> consumer = new DummyFlinkKafkaConsumer<>(true);
	setupConsumer(
		consumer,
		false,
		null,
		true, // enable checkpointing; auto commit should be ignored
		0,
		1);
	assertEquals(OffsetCommitMode.ON_CHECKPOINTS, consumer.getOffsetCommitMode());
}