Topic Messages: replication_table_difex.public.xtrn_iRAM_CDC_CDP

Partition: 0   Offset: 0   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":4,"CDC_id":"C04160301","Nam_CDC":"16-canal Gros","CDP_id":"CP4003","Nam_CDP":"CP-canal Gros- Alger"}
Partition: 0   Offset: 1   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":3,"CDC_id":"C04160302","Nam_CDC":"16-Canal Détail","CDP_id":"CP4004","Nam_CDP":"CP-Canal Détail- Alger"}
Partition: 0   Offset: 2   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":9,"CDC_id":"C04160303","Nam_CDC":"16-Canal Moderne A","CDP_id":"CP4005","Nam_CDP":"CP-Canal Moderne A Alger"}
Partition: 0   Offset: 3   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":6,"CDC_id":"C04160304","Nam_CDC":"16-Canal Moderne B","CDP_id":"CP4006","Nam_CDP":"CP-Canal Moderne B Alger"}
Partition: 0   Offset: 4   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":10,"CDC_id":"C04160305","Nam_CDC":"16-Canal B2B","CDP_id":"CP4007","Nam_CDP":"CP-Canal B2B Alger"}
Partition: 0   Offset: 5   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":14,"CDC_id":"C04160306","Nam_CDC":"16-Canal Sous-client","CDP_id":"CP4008","Nam_CDP":"CP-Canal Sous-client Alger"}
Partition: 0   Offset: 6   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":1,"CDC_id":"C04160307","Nam_CDC":"16-Canal sous-Distributeur","CDP_id":"CP4009","Nam_CDP":"CP-Canal sous-Distributeur Alger"}
Partition: 0   Offset: 7   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":15,"CDC_id":"C04160308","Nam_CDC":"16-Canal Prestation service","CDP_id":"CP4010","Nam_CDP":"CP-Canal Prestation service Alger"}
Partition: 0   Offset: 8   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":11,"CDC_id":"C04160309","Nam_CDC":"16-Canal HORECA","CDP_id":"CP4011","Nam_CDP":"CP-Canal HORECA Alger"}
Partition: 0   Offset: 9   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":16,"CDC_id":"C04160308","Nam_CDC":"16-Canal Prestation service","CDP_id":"CP4010","Nam_CDP":"CP-Canal Prestation service Alger"}
Partition: 0   Offset: 10   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":17,"CDC_id":"C04160309","Nam_CDC":"16-Canal HORECA","CDP_id":"CP4011","Nam_CDP":"CP-Canal HORECA Alger"}
Partition: 0   Offset: 11   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":6,"categ_id":4,"CDC_id":"C04190301","Nam_CDC":"19-canal Gros","CDP_id":"CP4013","Nam_CDP":"CP-canal Gros- sétif"}
Partition: 0   Offset: 12   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":6,"categ_id":3,"CDC_id":"C04190302","Nam_CDC":"19-Canal Détail","CDP_id":"CP4014","Nam_CDP":"CP-Canal Détail- sétif"}
Partition: 0   Offset: 13   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":6,"categ_id":9,"CDC_id":"C04190303","Nam_CDC":"19-Canal Moderne A","CDP_id":"CP4015","Nam_CDP":"CP-Canal Moderne A sétif"}
Partition: 0   Offset: 14   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":6,"categ_id":6,"CDC_id":"C04190304","Nam_CDC":"19-Canal Moderne B","CDP_id":"CP4016","Nam_CDP":"CP-Canal Moderne B sétif"}
Partition: 0   Offset: 15   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":6,"categ_id":10,"CDC_id":"C04190305","Nam_CDC":"19-Canal B2B","CDP_id":"CP4017","Nam_CDP":"CP-Canal B2B  sétif"}
Partition: 0   Offset: 0   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":4,"CDC_id":"C04160301","Nam_CDC":"16-canal Gros","CDP_id":"CP4003","Nam_CDP":"CP-canal Gros- Alger"}
Partition: 0   Offset: 1   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":3,"CDC_id":"C04160302","Nam_CDC":"16-Canal Détail","CDP_id":"CP4004","Nam_CDP":"CP-Canal Détail- Alger"}
Partition: 0   Offset: 2   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":9,"CDC_id":"C04160303","Nam_CDC":"16-Canal Moderne A","CDP_id":"CP4005","Nam_CDP":"CP-Canal Moderne A Alger"}
Partition: 0   Offset: 3   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":6,"CDC_id":"C04160304","Nam_CDC":"16-Canal Moderne B","CDP_id":"CP4006","Nam_CDP":"CP-Canal Moderne B Alger"}
Partition: 0   Offset: 4   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":10,"CDC_id":"C04160305","Nam_CDC":"16-Canal B2B","CDP_id":"CP4007","Nam_CDP":"CP-Canal B2B Alger"}
Partition: 0   Offset: 5   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":14,"CDC_id":"C04160306","Nam_CDC":"16-Canal Sous-client","CDP_id":"CP4008","Nam_CDP":"CP-Canal Sous-client Alger"}
Partition: 0   Offset: 6   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":1,"CDC_id":"C04160307","Nam_CDC":"16-Canal sous-Distributeur","CDP_id":"CP4009","Nam_CDP":"CP-Canal sous-Distributeur Alger"}
Partition: 0   Offset: 7   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":15,"CDC_id":"C04160308","Nam_CDC":"16-Canal Prestation service","CDP_id":"CP4010","Nam_CDP":"CP-Canal Prestation service Alger"}
Partition: 0   Offset: 8   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":11,"CDC_id":"C04160309","Nam_CDC":"16-Canal HORECA","CDP_id":"CP4011","Nam_CDP":"CP-Canal HORECA Alger"}
Partition: 0   Offset: 9   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":16,"CDC_id":"C04160308","Nam_CDC":"16-Canal Prestation service","CDP_id":"CP4010","Nam_CDP":"CP-Canal Prestation service Alger"}
Partition: 0   Offset: 10   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":1,"categ_id":17,"CDC_id":"C04160309","Nam_CDC":"16-Canal HORECA","CDP_id":"CP4011","Nam_CDP":"CP-Canal HORECA Alger"}
Partition: 0   Offset: 11   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":6,"categ_id":4,"CDC_id":"C04190301","Nam_CDC":"19-canal Gros","CDP_id":"CP4013","Nam_CDP":"CP-canal Gros- sétif"}
Partition: 0   Offset: 12   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":6,"categ_id":3,"CDC_id":"C04190302","Nam_CDC":"19-Canal Détail","CDP_id":"CP4014","Nam_CDP":"CP-Canal Détail- sétif"}
Partition: 0   Offset: 13   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":6,"categ_id":9,"CDC_id":"C04190303","Nam_CDC":"19-Canal Moderne A","CDP_id":"CP4015","Nam_CDP":"CP-Canal Moderne A sétif"}
Partition: 0   Offset: 14   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":6,"categ_id":6,"CDC_id":"C04190304","Nam_CDC":"19-Canal Moderne B","CDP_id":"CP4016","Nam_CDP":"CP-Canal Moderne B sétif"}
Partition: 0   Offset: 15   Key: empty   Timestamp: 2025-06-05 22:22:31.776 Headers: empty
  
{"warehouse_id":6,"categ_id":10,"CDC_id":"C04190305","Nam_CDC":"19-Canal B2B","CDP_id":"CP4017","Nam_CDP":"CP-Canal B2B  sétif"}
Partition: 0   Offset: 16   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":6,"categ_id":14,"CDC_id":"C04190306","Nam_CDC":"19-Canal Sous-client","CDP_id":"CP4018","Nam_CDP":"CP-Canal Sous-client sétif"}
Partition: 0   Offset: 17   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":6,"categ_id":1,"CDC_id":"C04190307","Nam_CDC":"19-Canal sous-Distributeur","CDP_id":"CP4019","Nam_CDP":"CP-Canal sous-Distributeur sétif"}
Partition: 0   Offset: 18   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":6,"categ_id":15,"CDC_id":"C04190308","Nam_CDC":"19-Canal Prestation service","CDP_id":"CP4020","Nam_CDP":"CP-Canal Prestation service sétif"}
Partition: 0   Offset: 19   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":6,"categ_id":11,"CDC_id":"C04190309","Nam_CDC":"19-Canal HORECA","CDP_id":"CP4021","Nam_CDP":"CP-Canal HORECA sétif"}
Partition: 0   Offset: 20   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":6,"categ_id":16,"CDC_id":"C04190308","Nam_CDC":"19-Canal Prestation service","CDP_id":"CP4020","Nam_CDP":"CP-Canal Prestation service sétif"}
Partition: 0   Offset: 21   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":6,"categ_id":17,"CDC_id":"C04190309","Nam_CDC":"19-Canal HORECA","CDP_id":"CP4021","Nam_CDP":"CP-Canal HORECA sétif"}
Partition: 0   Offset: 22   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":4,"CDC_id":"C04020301","Nam_CDC":"02-canal Gros","CDP_id":"CP4023","Nam_CDP":"CP-canal Gros Chlef"}
Partition: 0   Offset: 23   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":3,"CDC_id":"C04020302","Nam_CDC":"02-Canal Détail","CDP_id":"CP4024","Nam_CDP":"CP-Canal Détail Chlef"}
Partition: 0   Offset: 24   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":9,"CDC_id":"C04020303","Nam_CDC":"02-Canal Moderne A","CDP_id":"CP4025","Nam_CDP":"CP-Canal Moderne A  Chlef"}
Partition: 0   Offset: 25   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":6,"CDC_id":"C04020304","Nam_CDC":"02-Canal Moderne B","CDP_id":"CP4026","Nam_CDP":"CP-Canal Moderne B  Chlef"}
Partition: 0   Offset: 26   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":10,"CDC_id":"C04020305","Nam_CDC":"02-Canal B2B","CDP_id":"CP4027","Nam_CDP":"CP-Canal B2B  Chlef"}
Partition: 0   Offset: 27   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":14,"CDC_id":"C04020306","Nam_CDC":"02-Canal Sous-client","CDP_id":"CP4028","Nam_CDP":"CP-Canal Sous-client  Chlef"}
Partition: 0   Offset: 28   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":1,"CDC_id":"C04020307","Nam_CDC":"02-Canal sous-Distributeur","CDP_id":"CP4029","Nam_CDP":"CP-Canal sous-Distributeur  Chlef"}
Partition: 0   Offset: 29   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":15,"CDC_id":"C04020308","Nam_CDC":"02-Canal Prestation service","CDP_id":"CP4030","Nam_CDP":"CP-Canal Prestation service  Chlef"}
Partition: 0   Offset: 30   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":11,"CDC_id":"C04020309","Nam_CDC":"02-Canal HORECA","CDP_id":"CP4031","Nam_CDP":"CP-Canal HORECA  Chlef"}
Partition: 0   Offset: 31   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":16,"CDC_id":"C04020308","Nam_CDC":"02-Canal Prestation service","CDP_id":"CP4030","Nam_CDP":"CP-Canal Prestation service  Chlef"}
Partition: 0   Offset: 32   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":17,"CDC_id":"C04020309","Nam_CDC":"02-Canal HORECA","CDP_id":"CP4031","Nam_CDP":"CP-Canal HORECA  Chlef"}
Partition: 0   Offset: 33   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":4,"CDC_id":"C04250301","Nam_CDC":"25-canal Gros","CDP_id":"CP4033","Nam_CDP":"CP-canal Gros Constantine"}
Partition: 0   Offset: 34   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":3,"CDC_id":"C04250302","Nam_CDC":"25-Canal Détail","CDP_id":"CP4034","Nam_CDP":"CP-Canal Détail Constantine"}
Partition: 0   Offset: 35   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":9,"CDC_id":"C04250303","Nam_CDC":"25-Canal Moderne A","CDP_id":"CP4035","Nam_CDP":"CP-Canal Moderne A  Constantine"}
Partition: 0   Offset: 36   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":6,"CDC_id":"C04250304","Nam_CDC":"25-Canal Moderne B","CDP_id":"CP4036","Nam_CDP":"CP-Canal Moderne B  Constantine"}
Partition: 0   Offset: 37   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":10,"CDC_id":"C04250305","Nam_CDC":"25-Canal B2B","CDP_id":"CP4037","Nam_CDP":"CP-Canal B2B  Constantine"}
Partition: 0   Offset: 38   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":14,"CDC_id":"C04250306","Nam_CDC":"25-Canal Sous-client","CDP_id":"CP4038","Nam_CDP":"CP-Canal Sous-client  Constantine"}
Partition: 0   Offset: 39   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":1,"CDC_id":"C04250307","Nam_CDC":"25-Canal sous-Distributeur","CDP_id":"CP4039","Nam_CDP":"CP-Canal sous-Distributeur  Constantine"}
Partition: 0   Offset: 40   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":15,"CDC_id":"C04250308","Nam_CDC":"25-Canal Prestation service","CDP_id":"CP4040","Nam_CDP":"CP-Canal Prestation service  Constantine"}
Partition: 0   Offset: 41   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":11,"CDC_id":"C04250309","Nam_CDC":"25-Canal HORECA","CDP_id":"CP4041","Nam_CDP":"CP-Canal HORECA  Constantine"}
Partition: 0   Offset: 42   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":16,"CDC_id":"C04250308","Nam_CDC":"25-Canal Prestation service","CDP_id":"CP4040","Nam_CDP":"CP-Canal Prestation service  Constantine"}
Partition: 0   Offset: 43   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":17,"CDC_id":"C04250309","Nam_CDC":"25-Canal HORECA","CDP_id":"CP4041","Nam_CDP":"CP-Canal HORECA  Constantine"}
Partition: 0   Offset: 44   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":4,"CDC_id":"C04310301","Nam_CDC":"31-canal Gros","CDP_id":"CP4043","Nam_CDP":"CP-canal Gros Oran"}
Partition: 0   Offset: 45   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":3,"CDC_id":"C04310302","Nam_CDC":"31-Canal Détail","CDP_id":"CP4044","Nam_CDP":"CP-Canal Détail Oran"}
Partition: 0   Offset: 46   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":9,"CDC_id":"C04310303","Nam_CDC":"31-Canal Moderne A","CDP_id":"CP4045","Nam_CDP":"CP-Canal Moderne A  Oran"}
Partition: 0   Offset: 47   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":6,"CDC_id":"C04310304","Nam_CDC":"31-Canal Moderne B","CDP_id":"CP4046","Nam_CDP":"CP-Canal Moderne B  Oran"}
Partition: 0   Offset: 48   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":10,"CDC_id":"C04310305","Nam_CDC":"31-Canal B2B","CDP_id":"CP4047","Nam_CDP":"CP-Canal B2B  Oran"}
Partition: 0   Offset: 49   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":14,"CDC_id":"C04310306","Nam_CDC":"31-Canal Sous-client","CDP_id":"CP4048","Nam_CDP":"CP-Canal Sous-client  Oran"}
Partition: 0   Offset: 50   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":1,"CDC_id":"C04310307","Nam_CDC":"31-Canal sous-Distributeur","CDP_id":"CP4049","Nam_CDP":"CP-Canal sous-Distributeur  Oran"}
Partition: 0   Offset: 51   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":15,"CDC_id":"C04310308","Nam_CDC":"31-Canal Prestation service","CDP_id":"CP4050","Nam_CDP":"CP-Canal Prestation service  Oran"}
Partition: 0   Offset: 52   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":11,"CDC_id":"C04310309","Nam_CDC":"31-Canal HORECA","CDP_id":"CP4051","Nam_CDP":"CP-Canal HORECA  Oran"}
Partition: 0   Offset: 53   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":16,"CDC_id":"C04310308","Nam_CDC":"31-Canal Prestation service","CDP_id":"CP4050","Nam_CDP":"CP-Canal Prestation service  Oran"}
Partition: 0   Offset: 54   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":17,"CDC_id":"C04310309","Nam_CDC":"31-Canal HORECA","CDP_id":"CP4051","Nam_CDP":"CP-Canal HORECA  Oran"}
Partition: 0   Offset: 55   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":93,"categ_id":4,"CDC_id":"C04230301","Nam_CDC":"23-canal Gros","CDP_id":"CP4053","Nam_CDP":"CP-canal Gros Annaba"}
Partition: 0   Offset: 56   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":93,"categ_id":3,"CDC_id":"C04230302","Nam_CDC":"23-Canal Détail","CDP_id":"CP4054","Nam_CDP":"CP-Canal Détail Annaba"}
Partition: 0   Offset: 57   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":93,"categ_id":9,"CDC_id":"C04230303","Nam_CDC":"23-Canal Moderne A","CDP_id":"CP4055","Nam_CDP":"CP-Canal Moderne A  Annaba"}
Partition: 0   Offset: 58   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":93,"categ_id":6,"CDC_id":"C04230304","Nam_CDC":"23-Canal Moderne B","CDP_id":"CP4056","Nam_CDP":"CP-Canal Moderne B  Annaba"}
Partition: 0   Offset: 59   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":93,"categ_id":10,"CDC_id":"C04230305","Nam_CDC":"23-Canal B2B","CDP_id":"CP4057","Nam_CDP":"CP-Canal B2B  Annaba"}
Partition: 0   Offset: 60   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":93,"categ_id":14,"CDC_id":"C04230306","Nam_CDC":"23-Canal Sous-client","CDP_id":"CP4058","Nam_CDP":"CP-Canal Sous-client  Annaba"}
Partition: 0   Offset: 61   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":93,"categ_id":1,"CDC_id":"C04230307","Nam_CDC":"23-Canal sous-Distributeur","CDP_id":"CP4059","Nam_CDP":"CP-Canal sous-Distributeur  Annaba"}
Partition: 0   Offset: 16   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":6,"categ_id":14,"CDC_id":"C04190306","Nam_CDC":"19-Canal Sous-client","CDP_id":"CP4018","Nam_CDP":"CP-Canal Sous-client sétif"}
Partition: 0   Offset: 17   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":6,"categ_id":1,"CDC_id":"C04190307","Nam_CDC":"19-Canal sous-Distributeur","CDP_id":"CP4019","Nam_CDP":"CP-Canal sous-Distributeur sétif"}
Partition: 0   Offset: 18   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":6,"categ_id":15,"CDC_id":"C04190308","Nam_CDC":"19-Canal Prestation service","CDP_id":"CP4020","Nam_CDP":"CP-Canal Prestation service sétif"}
Partition: 0   Offset: 19   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":6,"categ_id":11,"CDC_id":"C04190309","Nam_CDC":"19-Canal HORECA","CDP_id":"CP4021","Nam_CDP":"CP-Canal HORECA sétif"}
Partition: 0   Offset: 20   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":6,"categ_id":16,"CDC_id":"C04190308","Nam_CDC":"19-Canal Prestation service","CDP_id":"CP4020","Nam_CDP":"CP-Canal Prestation service sétif"}
Partition: 0   Offset: 21   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":6,"categ_id":17,"CDC_id":"C04190309","Nam_CDC":"19-Canal HORECA","CDP_id":"CP4021","Nam_CDP":"CP-Canal HORECA sétif"}
Partition: 0   Offset: 22   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":4,"CDC_id":"C04020301","Nam_CDC":"02-canal Gros","CDP_id":"CP4023","Nam_CDP":"CP-canal Gros Chlef"}
Partition: 0   Offset: 23   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":3,"CDC_id":"C04020302","Nam_CDC":"02-Canal Détail","CDP_id":"CP4024","Nam_CDP":"CP-Canal Détail Chlef"}
Partition: 0   Offset: 24   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":9,"CDC_id":"C04020303","Nam_CDC":"02-Canal Moderne A","CDP_id":"CP4025","Nam_CDP":"CP-Canal Moderne A  Chlef"}
Partition: 0   Offset: 25   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":6,"CDC_id":"C04020304","Nam_CDC":"02-Canal Moderne B","CDP_id":"CP4026","Nam_CDP":"CP-Canal Moderne B  Chlef"}
Partition: 0   Offset: 26   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":10,"CDC_id":"C04020305","Nam_CDC":"02-Canal B2B","CDP_id":"CP4027","Nam_CDP":"CP-Canal B2B  Chlef"}
Partition: 0   Offset: 27   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":14,"CDC_id":"C04020306","Nam_CDC":"02-Canal Sous-client","CDP_id":"CP4028","Nam_CDP":"CP-Canal Sous-client  Chlef"}
Partition: 0   Offset: 28   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":1,"CDC_id":"C04020307","Nam_CDC":"02-Canal sous-Distributeur","CDP_id":"CP4029","Nam_CDP":"CP-Canal sous-Distributeur  Chlef"}
Partition: 0   Offset: 29   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":15,"CDC_id":"C04020308","Nam_CDC":"02-Canal Prestation service","CDP_id":"CP4030","Nam_CDP":"CP-Canal Prestation service  Chlef"}
Partition: 0   Offset: 30   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":11,"CDC_id":"C04020309","Nam_CDC":"02-Canal HORECA","CDP_id":"CP4031","Nam_CDP":"CP-Canal HORECA  Chlef"}
Partition: 0   Offset: 31   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":16,"CDC_id":"C04020308","Nam_CDC":"02-Canal Prestation service","CDP_id":"CP4030","Nam_CDP":"CP-Canal Prestation service  Chlef"}
Partition: 0   Offset: 32   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":10,"categ_id":17,"CDC_id":"C04020309","Nam_CDC":"02-Canal HORECA","CDP_id":"CP4031","Nam_CDP":"CP-Canal HORECA  Chlef"}
Partition: 0   Offset: 33   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":4,"CDC_id":"C04250301","Nam_CDC":"25-canal Gros","CDP_id":"CP4033","Nam_CDP":"CP-canal Gros Constantine"}
Partition: 0   Offset: 34   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":3,"CDC_id":"C04250302","Nam_CDC":"25-Canal Détail","CDP_id":"CP4034","Nam_CDP":"CP-Canal Détail Constantine"}
Partition: 0   Offset: 35   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":9,"CDC_id":"C04250303","Nam_CDC":"25-Canal Moderne A","CDP_id":"CP4035","Nam_CDP":"CP-Canal Moderne A  Constantine"}
Partition: 0   Offset: 36   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":6,"CDC_id":"C04250304","Nam_CDC":"25-Canal Moderne B","CDP_id":"CP4036","Nam_CDP":"CP-Canal Moderne B  Constantine"}
Partition: 0   Offset: 37   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":10,"CDC_id":"C04250305","Nam_CDC":"25-Canal B2B","CDP_id":"CP4037","Nam_CDP":"CP-Canal B2B  Constantine"}
Partition: 0   Offset: 38   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":14,"CDC_id":"C04250306","Nam_CDC":"25-Canal Sous-client","CDP_id":"CP4038","Nam_CDP":"CP-Canal Sous-client  Constantine"}
Partition: 0   Offset: 39   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":1,"CDC_id":"C04250307","Nam_CDC":"25-Canal sous-Distributeur","CDP_id":"CP4039","Nam_CDP":"CP-Canal sous-Distributeur  Constantine"}
Partition: 0   Offset: 40   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":15,"CDC_id":"C04250308","Nam_CDC":"25-Canal Prestation service","CDP_id":"CP4040","Nam_CDP":"CP-Canal Prestation service  Constantine"}
Partition: 0   Offset: 41   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":11,"CDC_id":"C04250309","Nam_CDC":"25-Canal HORECA","CDP_id":"CP4041","Nam_CDP":"CP-Canal HORECA  Constantine"}
Partition: 0   Offset: 42   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":16,"CDC_id":"C04250308","Nam_CDC":"25-Canal Prestation service","CDP_id":"CP4040","Nam_CDP":"CP-Canal Prestation service  Constantine"}
Partition: 0   Offset: 43   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":13,"categ_id":17,"CDC_id":"C04250309","Nam_CDC":"25-Canal HORECA","CDP_id":"CP4041","Nam_CDP":"CP-Canal HORECA  Constantine"}
Partition: 0   Offset: 44   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":4,"CDC_id":"C04310301","Nam_CDC":"31-canal Gros","CDP_id":"CP4043","Nam_CDP":"CP-canal Gros Oran"}
Partition: 0   Offset: 45   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":3,"CDC_id":"C04310302","Nam_CDC":"31-Canal Détail","CDP_id":"CP4044","Nam_CDP":"CP-Canal Détail Oran"}
Partition: 0   Offset: 46   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":9,"CDC_id":"C04310303","Nam_CDC":"31-Canal Moderne A","CDP_id":"CP4045","Nam_CDP":"CP-Canal Moderne A  Oran"}
Partition: 0   Offset: 47   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":6,"CDC_id":"C04310304","Nam_CDC":"31-Canal Moderne B","CDP_id":"CP4046","Nam_CDP":"CP-Canal Moderne B  Oran"}
Partition: 0   Offset: 48   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":10,"CDC_id":"C04310305","Nam_CDC":"31-Canal B2B","CDP_id":"CP4047","Nam_CDP":"CP-Canal B2B  Oran"}
Partition: 0   Offset: 49   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":14,"CDC_id":"C04310306","Nam_CDC":"31-Canal Sous-client","CDP_id":"CP4048","Nam_CDP":"CP-Canal Sous-client  Oran"}
Partition: 0   Offset: 50   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":1,"CDC_id":"C04310307","Nam_CDC":"31-Canal sous-Distributeur","CDP_id":"CP4049","Nam_CDP":"CP-Canal sous-Distributeur  Oran"}
Partition: 0   Offset: 51   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":15,"CDC_id":"C04310308","Nam_CDC":"31-Canal Prestation service","CDP_id":"CP4050","Nam_CDP":"CP-Canal Prestation service  Oran"}
Partition: 0   Offset: 52   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":11,"CDC_id":"C04310309","Nam_CDC":"31-Canal HORECA","CDP_id":"CP4051","Nam_CDP":"CP-Canal HORECA  Oran"}
Partition: 0   Offset: 53   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":16,"CDC_id":"C04310308","Nam_CDC":"31-Canal Prestation service","CDP_id":"CP4050","Nam_CDP":"CP-Canal Prestation service  Oran"}
Partition: 0   Offset: 54   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":14,"categ_id":17,"CDC_id":"C04310309","Nam_CDC":"31-Canal HORECA","CDP_id":"CP4051","Nam_CDP":"CP-Canal HORECA  Oran"}
Partition: 0   Offset: 55   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":93,"categ_id":4,"CDC_id":"C04230301","Nam_CDC":"23-canal Gros","CDP_id":"CP4053","Nam_CDP":"CP-canal Gros Annaba"}
Partition: 0   Offset: 56   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":93,"categ_id":3,"CDC_id":"C04230302","Nam_CDC":"23-Canal Détail","CDP_id":"CP4054","Nam_CDP":"CP-Canal Détail Annaba"}
Partition: 0   Offset: 57   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":93,"categ_id":9,"CDC_id":"C04230303","Nam_CDC":"23-Canal Moderne A","CDP_id":"CP4055","Nam_CDP":"CP-Canal Moderne A  Annaba"}
Partition: 0   Offset: 58   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":93,"categ_id":6,"CDC_id":"C04230304","Nam_CDC":"23-Canal Moderne B","CDP_id":"CP4056","Nam_CDP":"CP-Canal Moderne B  Annaba"}
Partition: 0   Offset: 59   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":93,"categ_id":10,"CDC_id":"C04230305","Nam_CDC":"23-Canal B2B","CDP_id":"CP4057","Nam_CDP":"CP-Canal B2B  Annaba"}
Partition: 0   Offset: 60   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":93,"categ_id":14,"CDC_id":"C04230306","Nam_CDC":"23-Canal Sous-client","CDP_id":"CP4058","Nam_CDP":"CP-Canal Sous-client  Annaba"}
Partition: 0   Offset: 61   Key: empty   Timestamp: 2025-06-05 22:22:31.777 Headers: empty
  
{"warehouse_id":93,"categ_id":1,"CDC_id":"C04230307","Nam_CDC":"23-Canal sous-Distributeur","CDP_id":"CP4059","Nam_CDP":"CP-Canal sous-Distributeur  Annaba"}
Partition: 0   Offset: 62   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":93,"categ_id":15,"CDC_id":"C04230308","Nam_CDC":"23-Canal Prestation service","CDP_id":"CP4060","Nam_CDP":"CP-Canal Prestation service  Annaba"}
Partition: 0   Offset: 63   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":93,"categ_id":11,"CDC_id":"C04230309","Nam_CDC":"23-Canal HORECA","CDP_id":"CP4061","Nam_CDP":"CP-Canal HORECA  Annaba"}
Partition: 0   Offset: 64   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":93,"categ_id":16,"CDC_id":"C04230308","Nam_CDC":"23-Canal Prestation service","CDP_id":"CP4060","Nam_CDP":"CP-Canal Prestation service  Annaba"}
Partition: 0   Offset: 65   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":93,"categ_id":17,"CDC_id":"C04230309","Nam_CDC":"23-Canal HORECA","CDP_id":"CP4061","Nam_CDP":"CP-Canal HORECA  Annaba"}
Partition: 0   Offset: 66   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":4,"CDC_id":"C04040301","Nam_CDC":"04-canal Gros","CDP_id":"CP4063","Nam_CDP":"CP-canal Gros Oum El bouagui"}
Partition: 0   Offset: 67   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":3,"CDC_id":"C04040302","Nam_CDC":"04-Canal Détail","CDP_id":"CP4064","Nam_CDP":"CP-Canal Détail Oum El bouagui"}
Partition: 0   Offset: 68   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":9,"CDC_id":"C04040303","Nam_CDC":"04-Canal Moderne A","CDP_id":"CP4065","Nam_CDP":"CP-Canal Moderne A  Oum El bouagui"}
Partition: 0   Offset: 69   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":6,"CDC_id":"C04040304","Nam_CDC":"04-Canal Moderne B","CDP_id":"CP4066","Nam_CDP":"CP-Canal Moderne B  Oum El bouagui"}
Partition: 0   Offset: 70   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":10,"CDC_id":"C04040305","Nam_CDC":"04-Canal B2B","CDP_id":"CP4067","Nam_CDP":"CP-Canal B2B  Oum El bouagui"}
Partition: 0   Offset: 71   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":14,"CDC_id":"C04040306","Nam_CDC":"04-Canal Sous-client","CDP_id":"CP4068","Nam_CDP":"CP-Canal Sous-client  Oum El bouagui"}
Partition: 0   Offset: 72   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":1,"CDC_id":"C04040307","Nam_CDC":"04-Canal sous-Distributeur","CDP_id":"CP4069","Nam_CDP":"CP-Canal sous-Distributeur  Oum El bouagui"}
Partition: 0   Offset: 73   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":15,"CDC_id":"C04040308","Nam_CDC":"04-Canal Prestation service","CDP_id":"CP4070","Nam_CDP":"CP-Canal Prestation service  Oum El bouagui"}
Partition: 0   Offset: 74   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":11,"CDC_id":"C04040309","Nam_CDC":"04-Canal HORECA","CDP_id":"CP4071","Nam_CDP":"CP-Canal HORECA  Oum El bouagui"}
Partition: 0   Offset: 75   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":16,"CDC_id":"C04040308","Nam_CDC":"04-Canal Prestation service","CDP_id":"CP4070","Nam_CDP":"CP-Canal Prestation service  Oum El bouagui"}
Partition: 0   Offset: 76   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":17,"CDC_id":"C04040309","Nam_CDC":"04-Canal HORECA","CDP_id":"CP4071","Nam_CDP":"CP-Canal HORECA  Oum El bouagui"}
Partition: 0   Offset: 77   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":4,"CDC_id":"C04420301","Nam_CDC":"42-canal Gros","CDP_id":"CP4003","Nam_CDP":"CP-canal Gros- Tipaza"}
Partition: 0   Offset: 78   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":3,"CDC_id":"C04420302","Nam_CDC":"42-Canal Détail","CDP_id":"CP4004","Nam_CDP":"CP-Canal Détail- Tipaza"}
Partition: 0   Offset: 79   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":9,"CDC_id":"C04420303","Nam_CDC":"42-Canal Moderne A","CDP_id":"CP4005","Nam_CDP":"CP-Canal Moderne A Tipaza"}
Partition: 0   Offset: 80   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":6,"CDC_id":"C04420304","Nam_CDC":"42-Canal Moderne B","CDP_id":"CP4006","Nam_CDP":"CP-Canal Moderne B Tipaza"}
Partition: 0   Offset: 81   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":10,"CDC_id":"C04420305","Nam_CDC":"42-Canal B2B","CDP_id":"CP4007","Nam_CDP":"CP-Canal B2B Tipaza"}
Partition: 0   Offset: 82   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":14,"CDC_id":"C04420306","Nam_CDC":"42-Canal Sous-client","CDP_id":"CP4008","Nam_CDP":"CP-Canal Sous-client Tipaza"}
Partition: 0   Offset: 83   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":1,"CDC_id":"C04420307","Nam_CDC":"42-Canal sous-Distributeur","CDP_id":"CP4009","Nam_CDP":"CP-Canal sous-Distributeur Tipaza"}
Partition: 0   Offset: 84   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":15,"CDC_id":"C04420308","Nam_CDC":"42-Canal Prestation service","CDP_id":"CP4010","Nam_CDP":"CP-Canal Prestation service Tipaza"}
Partition: 0   Offset: 85   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":11,"CDC_id":"C04420309","Nam_CDC":"42-Canal HORECA","CDP_id":"CP4011","Nam_CDP":"CP-Canal HORECA Tipaza"}
Partition: 0   Offset: 86   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":16,"CDC_id":"C04420308","Nam_CDC":"42-Canal Prestation service","CDP_id":"CP4010","Nam_CDP":"CP-Canal Prestation service Tipaza"}
Partition: 0   Offset: 87   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":17,"CDC_id":"C04420309","Nam_CDC":"42-Canal HORECA","CDP_id":"CP4011","Nam_CDP":"CP-Canal HORECA Tipaza"}
Partition: 0   Offset: 62   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":93,"categ_id":15,"CDC_id":"C04230308","Nam_CDC":"23-Canal Prestation service","CDP_id":"CP4060","Nam_CDP":"CP-Canal Prestation service  Annaba"}
Partition: 0   Offset: 63   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":93,"categ_id":11,"CDC_id":"C04230309","Nam_CDC":"23-Canal HORECA","CDP_id":"CP4061","Nam_CDP":"CP-Canal HORECA  Annaba"}
Partition: 0   Offset: 64   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":93,"categ_id":16,"CDC_id":"C04230308","Nam_CDC":"23-Canal Prestation service","CDP_id":"CP4060","Nam_CDP":"CP-Canal Prestation service  Annaba"}
Partition: 0   Offset: 65   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":93,"categ_id":17,"CDC_id":"C04230309","Nam_CDC":"23-Canal HORECA","CDP_id":"CP4061","Nam_CDP":"CP-Canal HORECA  Annaba"}
Partition: 0   Offset: 66   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":4,"CDC_id":"C04040301","Nam_CDC":"04-canal Gros","CDP_id":"CP4063","Nam_CDP":"CP-canal Gros Oum El bouagui"}
Partition: 0   Offset: 67   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":3,"CDC_id":"C04040302","Nam_CDC":"04-Canal Détail","CDP_id":"CP4064","Nam_CDP":"CP-Canal Détail Oum El bouagui"}
Partition: 0   Offset: 68   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":9,"CDC_id":"C04040303","Nam_CDC":"04-Canal Moderne A","CDP_id":"CP4065","Nam_CDP":"CP-Canal Moderne A  Oum El bouagui"}
Partition: 0   Offset: 69   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":6,"CDC_id":"C04040304","Nam_CDC":"04-Canal Moderne B","CDP_id":"CP4066","Nam_CDP":"CP-Canal Moderne B  Oum El bouagui"}
Partition: 0   Offset: 70   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":10,"CDC_id":"C04040305","Nam_CDC":"04-Canal B2B","CDP_id":"CP4067","Nam_CDP":"CP-Canal B2B  Oum El bouagui"}
Partition: 0   Offset: 71   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":14,"CDC_id":"C04040306","Nam_CDC":"04-Canal Sous-client","CDP_id":"CP4068","Nam_CDP":"CP-Canal Sous-client  Oum El bouagui"}
Partition: 0   Offset: 72   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":1,"CDC_id":"C04040307","Nam_CDC":"04-Canal sous-Distributeur","CDP_id":"CP4069","Nam_CDP":"CP-Canal sous-Distributeur  Oum El bouagui"}
Partition: 0   Offset: 73   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":15,"CDC_id":"C04040308","Nam_CDC":"04-Canal Prestation service","CDP_id":"CP4070","Nam_CDP":"CP-Canal Prestation service  Oum El bouagui"}
Partition: 0   Offset: 74   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":11,"CDC_id":"C04040309","Nam_CDC":"04-Canal HORECA","CDP_id":"CP4071","Nam_CDP":"CP-Canal HORECA  Oum El bouagui"}
Partition: 0   Offset: 75   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":16,"CDC_id":"C04040308","Nam_CDC":"04-Canal Prestation service","CDP_id":"CP4070","Nam_CDP":"CP-Canal Prestation service  Oum El bouagui"}
Partition: 0   Offset: 76   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":107,"categ_id":17,"CDC_id":"C04040309","Nam_CDC":"04-Canal HORECA","CDP_id":"CP4071","Nam_CDP":"CP-Canal HORECA  Oum El bouagui"}
Partition: 0   Offset: 77   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":4,"CDC_id":"C04420301","Nam_CDC":"42-canal Gros","CDP_id":"CP4003","Nam_CDP":"CP-canal Gros- Tipaza"}
Partition: 0   Offset: 78   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":3,"CDC_id":"C04420302","Nam_CDC":"42-Canal Détail","CDP_id":"CP4004","Nam_CDP":"CP-Canal Détail- Tipaza"}
Partition: 0   Offset: 79   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":9,"CDC_id":"C04420303","Nam_CDC":"42-Canal Moderne A","CDP_id":"CP4005","Nam_CDP":"CP-Canal Moderne A Tipaza"}
Partition: 0   Offset: 80   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":6,"CDC_id":"C04420304","Nam_CDC":"42-Canal Moderne B","CDP_id":"CP4006","Nam_CDP":"CP-Canal Moderne B Tipaza"}
Partition: 0   Offset: 81   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":10,"CDC_id":"C04420305","Nam_CDC":"42-Canal B2B","CDP_id":"CP4007","Nam_CDP":"CP-Canal B2B Tipaza"}
Partition: 0   Offset: 82   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":14,"CDC_id":"C04420306","Nam_CDC":"42-Canal Sous-client","CDP_id":"CP4008","Nam_CDP":"CP-Canal Sous-client Tipaza"}
Partition: 0   Offset: 83   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":1,"CDC_id":"C04420307","Nam_CDC":"42-Canal sous-Distributeur","CDP_id":"CP4009","Nam_CDP":"CP-Canal sous-Distributeur Tipaza"}
Partition: 0   Offset: 84   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":15,"CDC_id":"C04420308","Nam_CDC":"42-Canal Prestation service","CDP_id":"CP4010","Nam_CDP":"CP-Canal Prestation service Tipaza"}
Partition: 0   Offset: 85   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":11,"CDC_id":"C04420309","Nam_CDC":"42-Canal HORECA","CDP_id":"CP4011","Nam_CDP":"CP-Canal HORECA Tipaza"}
Partition: 0   Offset: 86   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":16,"CDC_id":"C04420308","Nam_CDC":"42-Canal Prestation service","CDP_id":"CP4010","Nam_CDP":"CP-Canal Prestation service Tipaza"}
Partition: 0   Offset: 87   Key: empty   Timestamp: 2025-06-05 22:22:31.778 Headers: empty
  
{"warehouse_id":157,"categ_id":17,"CDC_id":"C04420309","Nam_CDC":"42-Canal HORECA","CDP_id":"CP4011","Nam_CDP":"CP-Canal HORECA Tipaza"}