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

    final ByLogicalTableRouter<SourceRecord> subject = new ByLogicalTableRouter<>();
    final Map<String, String> props = new HashMap<>();
    // topic.replacement is not set, therefore null. Must crash.
    props.put("topic.regex", "someValidRegex(.*)");
    subject.configure(props);
}