@Override
    public DataType getType() {
        return DataType.META_DATA;
    }
@Test
    public void testGetType() {
        Assertions.assertEquals(DataType.META_DATA, metadataExecutorSubscriber.getType());
    }