@Test(expected = IllegalArgumentException.class)
public void testCreateConnectionDestGroupNotFound() {

    final String flowId = flow.getFlowMetadata().getIdentifier();
    final String groupId = group2.getIdentifier();
    when(flowManager.getFlow(flowId)).thenReturn(Optional.of(flow));
    connectionConfig.getDestination().setGroupId("DOES-NOT-EXIST");
    connectionService.create(flowId, groupId, connectionConfig);
}