Hi,

I have kstream in our cluster. I am not sure how the schema is generated
for this. Dpes kstream have schema in schema registry?

How to move data from kstream to topic which has the same name? How to
register schema automatically for this?

This is how schema looks in our registry. My assumption was it was created
automatically. May I know how it was done.

{
  "type": "record",

*  "name": "KsqlDataSourceSchema",  "namespace":
"io.confluent.ksql.avro_schemas",*
  "fields": [
    {
      "name": "IN_EMP_ID",
      "type": [
        "null",
        "string"
      ],
      "default": null
    },
    {
      "name": "IN_SYSTEM_ID",
      "type": [
        "null",
        "string"
      ],
      "default": null
    },
    {
      "name": "IN_DIRECTORY_TITLE",
      "type": [
        "null",
        "string"
      ],
      "default": null
    },
    {
      "name": "IN_OFFICE_LOCATION",
      "type": [
        "null",
        "string"
      ],
      "default": null
    },
    {
      "name": "IN_DIRECTORY_DEPARTMENT",
      "type": [
        "null",
        "string"
      ],
      "default": null
    },
    {
      "name": "EMP_VISA_TYPE_CODE",
      "type": [
        "null",
        "string"
      ],
      "default": null
    },
    {
      "name": "EMP_CITIZENSHIP_CODE",
      "type": [
        "null",
        "string"
      ],
      "default": null
    },
    {
      "name": "IN_APP_TITLE_CODE",
      "type": [
        "null",
        "string"
      ],
      "default": null
    },
    {
      "name": "IN_APP_TITLE_NAME",
      "type": [
        "null",
        "string"
      ],
      "default": null
    }
  ]
}

Thanks,
Asmath

Reply via email to