@Test
public void ensureDefaultConnectTimeoutCorrect() {

  whenDefaultStringConfig();
  when(configContext.getInteger("connectTimeout", DEFAULT_CONNECT_TIMEOUT)).thenReturn(1000);
  when(configContext.getInteger(eq("requestTimeout"), Mockito.anyInt())).thenReturn(1000);
  new HttpSink().configure(configContext);
  verify(configContext).getInteger("connectTimeout", DEFAULT_CONNECT_TIMEOUT);
}