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