@Test
public void ensureDefaultRequestTimeoutCorrect() {

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