KafkaConfigValidator { public static void validate(Properties props) { verifyPropsNotNull(props); verifyAutoCommitDisabled(props); } private  KafkaConfigValidator(); static void validate(Properties props);  }
@Test public void testValidate() throws Exception { validate(testProps); }
@Test public void testValidateAutoCommitTrue() throws Exception { expected.expect(IllegalArgumentException.class); expected.expectMessage(AUTO_COMMIT_ENABLED_MSG); testProps.setProperty(ENABLE_AUTO_COMMIT_CONFIG, "true"); validate(testProps); }
@Test public void testValidateNullProperties() throws Exception { expected.expect(IllegalArgumentException.class); expected.expectMessage(NULL_PROPS_MESSAGE); validate(null); }