ashishmgofficial commented on issue #2149:
URL: https://github.com/apache/hudi/issues/2149#issuecomment-712377184
@bvaradar I can provide all the SQL's in Postgres which I'm using to
reproduce this though :
```
DROP TABLE public.motor_crash_violation_incidents;
CREATE TABLE public.motor_crash_violation_incidents (
inc_id serial ,
"year" int4 NULL,
violation_desc varchar(100) NULL,
violation_code varchar(20) NULL,
case_individual_id int4 NULL,
flag varchar(1) NULL,
last_modified_ts timestamp not NULL,
CONSTRAINT motor_crash_violation_incidents_pkey PRIMARY KEY (inc_id)
);
ALTER TABLE public.motor_crash_violation_incidents REPLICA IDENTITY FULL;
```
Insert records :
```
INSERT INTO public.motor_crash_violation_incidents
(inc_id, "year", violation_desc, violation_code, case_individual_id, flag,
last_modified_ts)
VALUES(1, 2016, 'DRIVING WHILE INTOXICATED', '11923', 17475366, 'I',
'2020-09-24 11:03:00.000');
commit;
INSERT INTO public.motor_crash_violation_incidents
(inc_id, "year", violation_desc, violation_code, case_individual_id, flag,
last_modified_ts)
VALUES(3, 2016, 'AGGRAVATED UNLIC OPER 2ND/PREV CONV', '5112A1', 17475367,
'U', '2020-09-24 15:00:00.000');
commit;
INSERT INTO public.motor_crash_violation_incidents
(inc_id, "year", violation_desc, violation_code, case_individual_id, flag,
last_modified_ts)
VALUES(4, 2019, 'AGGRAVATED UNLIC OPER 2ND/PREV', '5112A2', 17475368, 'I',
'2019-09-24 15:00:00.000');
commit;
INSERT INTO public.motor_crash_violation_incidents
(inc_id, "year", violation_desc, violation_code, case_individual_id, flag,
last_modified_ts)
VALUES(2, 2020, 'UNREASONABLE SPEED/SPECIAL HAZARDS', '2180F', 17475569,
'U', '2020-09-29 11:00:00.000');
commit;
INSERT INTO public.motor_crash_violation_incidents
(inc_id, "year", violation_desc, violation_code, case_individual_id, flag,
last_modified_ts)
VALUES(9, 2020, 'UNREASONABLE SPEED/SPECIAL HAZARDS', '1180E', 17475573,
'I', '2020-09-29 11:00:00.000');
commit;
INSERT INTO public.motor_crash_violation_incidents
(inc_id, "year", violation_desc, violation_code, case_individual_id, flag,
last_modified_ts)
VALUES(10, 2020, 'UNREASONABLE SPEED/SPECIAL HAZARDS', '1180D', 17475574,
'I', '2020-09-29 11:10:00.000');
commit;
INSERT INTO public.motor_crash_violation_incidents
(inc_id, "year", violation_desc, violation_code, case_individual_id, flag,
last_modified_ts)
VALUES(11, 2020, 'UNREASONABLE SPEED/SPECIAL HAZARDS', '1180D', 17475574,
'I', '2020-09-29 12:10:00.000');
commit;
INSERT INTO public.motor_crash_violation_incidents
(inc_id, "year", violation_desc, violation_code, case_individual_id, flag,
last_modified_ts)
VALUES(12, 2020, 'UNREASONABLE SPEED/SPECIAL HAZARDS', '1180E', 17475574,
'I', '2020-09-29 13:10:00.000');
commit;
INSERT INTO public.motor_crash_violation_incidents
(inc_id, "year", violation_desc, violation_code, case_individual_id, flag,
last_modified_ts)
VALUES(13, 2020, 'UNREASONABLE SPEED/SPECIAL HAZARDS', '1180E', 17475574,
'I', '2020-09-29 14:10:00.000');
commit;
INSERT INTO public.motor_crash_violation_incidents
(inc_id, "year", violation_desc, violation_code, case_individual_id, flag,
last_modified_ts)
VALUES(34, 2020, 'UNREASONABLE SPEED/SPECIAL HAZARDS', '1180E', 17475574,
'I', '2020-09-29 15:10:00.000');
commit;
INSERT INTO public.motor_crash_violation_incidents
(inc_id, "year", violation_desc, violation_code, case_individual_id, flag,
last_modified_ts)
VALUES(35, 2020, 'UNREASONABLE SPEED/SPECIAL HAZARDS', '1180E', 17475574,
'I', '2020-09-29 16:10:00.000');
commit;
INSERT INTO public.motor_crash_violation_incidents
(inc_id, "year", violation_desc, violation_code, case_individual_id, flag,
last_modified_ts)
VALUES(36, 2020, 'UNREASONABLE SPEED/SPECIAL HAZARDS', '1180E', 17475574,
'I', '2020-09-29 17:00:00.000');
commit;
INSERT INTO public.motor_crash_violation_incidents
(inc_id, "year", violation_desc, violation_code, case_individual_id, flag,
last_modified_ts)
VALUES(37, 2020, 'UNREASONABLE SPEED/SPECIAL HAZARDS', '1180E', 17475574,
'I', '2020-09-29 17:10:00.000');
commit;
INSERT INTO public.motor_crash_violation_incidents
(inc_id, "year", violation_desc, violation_code, case_individual_id, flag,
last_modified_ts)
VALUES(38, 2020, 'UNREASONABLE SPEED/SPECIAL HAZARDS', '1180D', 17475574,
'I', '2020-09-29 18:00:00.000');
commit;
```
Issue Delete :
```
DELETE FROM public.motor_crash_violation_incidents
WHERE inc_id=3;
```
These changes are automatically picked by the Confluent Kafka's Postgres
Debezium Connector and written to topic
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
