@Test
public void testConfigureDisableOffsetCommitWithoutCheckpointing() throws Exception {

	@SuppressWarnings("unchecked")
	final DummyFlinkKafkaConsumer<String> consumer = new DummyFlinkKafkaConsumer<>(false);
	setupConsumer(
		consumer,
		false,
		null,
		false, // disable checkpointing; auto commit should be respected
		0,
		1);
	assertEquals(OffsetCommitMode.DISABLED, consumer.getOffsetCommitMode());
}