@Override
    public Producer createProducer() throws Exception {
        throw new UnsupportedOperationException(
                "Cannot produce from a DebeziumEndpoint: "
                                                + getEndpointUri());
    }
@Test
    void testIfFailsToCreateProducer() {
        assertThrows(UnsupportedOperationException.class, () -> {
            debeziumEndpoint.createProducer();
        });
    }