@Override
  public @UnknownKeyFor @NonNull @Initialized String identifier() {
    return "beam:schematransform:org.apache.beam:kafka_write:v1";
  }
@Test
  public void testManagedMappings() {
    KafkaWriteSchemaTransformProvider provider = new KafkaWriteSchemaTransformProvider();
    Map<String, String> mapping = ManagedTransformConstants.MAPPINGS.get(provider.identifier());

    assertNotNull(mapping);

    List<String> configSchemaFieldNames = provider.configurationSchema().getFieldNames();
    for (String paramName : mapping.values()) {
      assertTrue(configSchemaFieldNames.contains(paramName));
    }
  }