@Override
    public Consumer createConsumer(Processor processor) throws Exception {
        DebeziumConsumer consumer = new DebeziumConsumer(this, processor);
        configureConsumer(consumer);
        return consumer;
    }
@Test
    void testIfCreatesConsumer() throws Exception {
        final Consumer debeziumConsumer = debeziumEndpoint.createConsumer(processor);

        assertNotNull(debeziumConsumer);
    }