You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "pierre bouvret (JIRA)" <ji...@apache.org> on 2019/03/27 13:15:00 UTC

[jira] [Created] (KAFKA-8163) SetSchemaMetadata SMT does not apply to nested types

pierre bouvret created KAFKA-8163:
-------------------------------------

             Summary: SetSchemaMetadata SMT does not apply to nested types
                 Key: KAFKA-8163
                 URL: https://issues.apache.org/jira/browse/KAFKA-8163
             Project: Kafka
          Issue Type: Bug
            Reporter: pierre bouvret


In a schema, I want to replace the pg.public.foufou namespace by the pg.other_public.foufou namespace.

The schema (Envelope from Debezium) has an inner definition for Value also belonging to the pg.public.foufou namespace

Using a SetSchemaMetadata SMT, the inner namespace is not updated.
{quote}{
    "type": "record",
    "name": "Envelope",
    "namespace": "pg.other_public.foufou",
    "fields": [
        {
            "name": "before",
            "type": [
                "null",
                {
                    "type": "record",
                    "name": "Value",
                    "namespace": "pg.public.foufou",
                    "fields": [
                        {
                            "name": "id",
                            "type": "int"
                        },
                        {
                            "name": "lib",
                            "type": [
                                "null",
                                "string"
                            ],
                            "default": null
                        }
                    ],
                    "connect.name": "pg.public.foufou.Value"
                }
            ],
            "default": null
        },{quote}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)