@Test(expected = ConnectException.class)
public void shouldFailOnInvalidConfigurationForOperationBehavior() {

    final EventRouter<SourceRecord> router = new EventRouter<>();
    final Map<String, String> config = new HashMap<>();
    config.put(EventRouterConfigDefinition.OPERATION_INVALID_BEHAVIOR.name(), "invalidOption");
    router.configure(config);
}