Tag: DEBEZIUM
Estoy tratando de aplicar el New Record State Extraction SMT de Debezium utilizando la siguiente configuración: “transforms”: “unwrap”, “transforms.unwrap.type”: “io.debezium.transforms.ExtractNewRecordState”, “transforms.unwrap.drop.tombstones”: true, “transforms.unwrap.delete.handling.mode”: “rewrite”, “transforms.unwrap.add.fields”: “db,schema,table,txId,ts_ms” Para las operaciones INSERT y UPDATE recibo los mensajes como se esperaba, pero en caso de DELETE recibo lo siguiente como carga de datos: . . . Read more
Tengo una instancia de debezium que realiza un seguimiento de los cambios en postgres y envía los mensajes de cambios a kafka. En el otro lado de kafka tengo kafka connect con el conector de destino de Amazon Redshift, y el formato de mensaje que espera este conector no es . . . Read more
Estoy probando Debezium con una conexión a Oracle por primera vez. Obtengo No se puede analizar el valor predeterminado de la columna '"MYUSER"."ISEQ$$_475890".nextval' al tipo '2'. La evaluación de expresiones no es compatible. (io.debezium.connector.oracle.OracleDefaultValueConverter) En una tabla que estoy probando hay dos columnas destacadas: la primera es INTEGER generado de . . . Read more
Tenemos una instancia de SQL Server Always On. Quiero hacer un seguimiento de los eventos de CDC en algunas tablas utilizando Debezium. Siguiendo los tutoriales oficiales en el sitio web de Debezium, registré un conector con las siguientes propiedades: { "name": "debezium-alwayson-connector", "config": { "connector.class": "io.debezium.connector.sqlserver.SqlServerConnector", "database.hostname": "<ip-address>", "database.port": "1433", . . . Read more
Me gustaría añadir datos en tiempo real desde SQL Server a Kafka directamente y encontré que hay un conector de SQL Server proporcionado por https://debezium.io/docs/connectors/sqlserver/. En la documentación dice que se creará un tema por cada tabla. Estoy intentando entender la arquitectura porque tengo 500 clientes, lo que significa que . . . Read more