I am facing some issues while using schema registry in avro deserializer. error-
Caused by: org.apache.kafka.common.errors.SerializationException: Could not find class postgres.public.truck_histories.Envelope specified in writer's schema whilst finding reader's schema for a SpecificRecord.
i am using psql connector for generating schema from a table using curl request-
curl -H 'Content-Type: application/json' debezium:8083/connectors --data '{"name": "gps-connector", "config": {"connector.class": "io.debezium.connector.postgresql.PostgresConnector", "plugin.name": "pgoutput","database.hostname": "postgres", "database.port": "5432", "database.user": "postgres", "database.password": "password", "database.dbname" : "shipment_alert_subscriptions", "database.server.name": "postgres", "table.include.list": "public.truck_histories" }}'
but the generated schema has different name(Envelope) and namespace how can I configure those fields?
For your specific record, where do you get the schema?
Also, you probably want this
https://debezium.io/documentation/reference/stable/transformations/event-flattening.html
