Topic Messages: __consumer_offsets

Partition: 23   Offset: 15   Key: "notification.user_recipient.getted   Timestamp: 2026-03-31 12:55:54.636 Headers: empty
  
consumerrangejservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)-4f6ee12d-f6cb-44c6-9e02-d27844fc67e3�C�jservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)-4f6ee12d-f6cb-44c6-9e02-d27844fc67e3��Eservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)/10.131.0.4u0u03'user_recipient.user_recipient.getted.v1����;'user_recipient.user_recipient.getted.v1����
Partition: 18   Offset: 15   Key: orders-event-group   Timestamp: 2026-03-31 12:56:16.317 Headers: empty
  
consumerrangekservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)-1cf44991-c29d-42d3-85a5-c07751379759�C�V�kservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)-1cf44991-c29d-42d3-85a5-c07751379759��Fservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)
/10.114.133.5u0u0"order.order.created.v1����*order.order.created.v1����
Partition: 43   Offset: 15   Key: 'notification.notification_email.created   Timestamp: 2026-03-31 12:56:16.317 Headers: empty
  
consumerrangejservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)-4fe0523e-3628-4e30-8b35-2478a30b0ce1�C�V�jservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)-4fe0523e-3628-4e30-8b35-2478a30b0ce1��Eservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)
/10.114.133.3u0u06*notification.notification_email.created.v1����>*notification.notification_email.created.v1����
Partition: 38   Offset: 9   Key: $notification.notification_tg.created   Timestamp: 2026-04-01 17:54:33.513 Headers: empty
  
consumer	rangeiservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)-5767453c-6f3c-4099-8a80-3c586c6653be�J.ɣiservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)-5767453c-6f3c-4099-8a80-3c586c6653be��Dservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)
/10.114.133.4u0u03'notification.notification_tg.created.v1����;'notification.notification_tg.created.v1����
Partition: 17   Offset: 8   Key: %notification.notification_raw.created   Timestamp: 2026-04-01 17:55:03.023 Headers: empty
  
consumerrangemservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)-62e989d2-6678-492c-afc2-07c69a8cbe26�J/<�mservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)-62e989d2-6678-492c-afc2-07c69a8cbe26��Hservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)
/10.114.129.7u0u04(notification.notification_raw.created.v1����<(notification.notification_raw.created.v1����
Partition: 23   Offset: 16   Key: "notification.user_recipient.getted   Timestamp: 2026-04-02 18:56:39.623 Headers: empty
  
consumerrangejservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)-6b268ee7-ccef-4cf3-b11e-012f104fa3cf�O��jservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)-6b268ee7-ccef-4cf3-b11e-012f104fa3cf��Eservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)/10.131.0.4u0u03'user_recipient.user_recipient.getted.v1����;'user_recipient.user_recipient.getted.v1����
Partition: 18   Offset: 16   Key: orders-event-group   Timestamp: 2026-04-02 18:56:39.630 Headers: empty
  
consumerrangekservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)-342cbdbf-2fe0-4ab7-b2e2-b2991fc6c81e�O��kservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)-342cbdbf-2fe0-4ab7-b2e2-b2991fc6c81e��Fservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)/10.131.0.6u0u0"order.order.created.v1����*order.order.created.v1����
Partition: 43   Offset: 16   Key: 'notification.notification_email.created   Timestamp: 2026-04-02 18:56:39.636 Headers: empty
  
consumerrangejservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)-c86abe13-5356-434e-8a54-202bb94ec0c5�O��jservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)-c86abe13-5356-434e-8a54-202bb94ec0c5��Eservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)/10.131.0.6u0u06*notification.notification_email.created.v1����>*notification.notification_email.created.v1����
Partition: 18   Offset: 17   Key: orders-event-group   Timestamp: 2026-04-02 19:01:02.641 Headers: empty
  
consumerrangekservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)-342cbdbf-2fe0-4ab7-b2e2-b2991fc6c81e�O�-kservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)-342cbdbf-2fe0-4ab7-b2e2-b2991fc6c81e��Fservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)/10.131.0.6u0u0"order.order.created.v1����*order.order.created.v1����
Partition: 43   Offset: 17   Key: 'notification.notification_email.created   Timestamp: 2026-04-02 19:01:31.123 Headers: empty
  
consumerrangejservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)-aa6a013a-a966-4740-ab61-80024fa59e4a�O�spjservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)-aa6a013a-a966-4740-ab61-80024fa59e4a��Eservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)
/10.114.133.3u0u06*notification.notification_email.created.v1����>*notification.notification_email.created.v1����
Partition: 23   Offset: 17   Key: "notification.user_recipient.getted   Timestamp: 2026-04-02 19:01:31.124 Headers: empty
  
consumerrangejservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)-8b11f950-f899-4900-b000-1e85cf4f20b4�O�sqjservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)-8b11f950-f899-4900-b000-1e85cf4f20b4��Eservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)/10.131.0.4u0u03'user_recipient.user_recipient.getted.v1����;'user_recipient.user_recipient.getted.v1����
Partition: 23   Offset: 18   Key: "notification.user_recipient.getted   Timestamp: 2026-04-03 20:34:56.816 Headers: empty
  
consumerrangejservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)-c50ed200-1b8a-4555-bd40-f8c4ec6439be�UX�jservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)-c50ed200-1b8a-4555-bd40-f8c4ec6439be��Eservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)/10.131.0.4u0u03'user_recipient.user_recipient.getted.v1����;'user_recipient.user_recipient.getted.v1����
Partition: 43   Offset: 18   Key: 'notification.notification_email.created   Timestamp: 2026-04-03 20:34:56.819 Headers: empty
  
consumerrangejservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)-911e8c00-2608-47ee-9885-27f43e7dec0e�UX�jservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)-911e8c00-2608-47ee-9885-27f43e7dec0e��Eservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)/10.131.0.6u0u06*notification.notification_email.created.v1����>*notification.notification_email.created.v1����
Partition: 18   Offset: 18   Key: orders-event-group   Timestamp: 2026-04-03 20:34:56.822 Headers: empty
  
consumerrangekservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)-6e7e2d80-7be0-4aec-8303-d42b6d5661ed�UX�kservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)-6e7e2d80-7be0-4aec-8303-d42b6d5661ed��Fservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)/10.131.0.6u0u0"order.order.created.v1����*order.order.created.v1����
Partition: 18   Offset: 19   Key: orders-event-group   Timestamp: 2026-04-03 20:39:26.866 Headers: empty
  
consumerrangekservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)-6e7e2d80-7be0-4aec-8303-d42b6d5661ed�Uw�kservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)-6e7e2d80-7be0-4aec-8303-d42b6d5661ed��Fservice@user-recipient-b486d4f65-5m92g (github.com/segmentio/kafka-go)/10.131.0.6u0u0"order.order.created.v1����*order.order.created.v1����
Partition: 43   Offset: 19   Key: 'notification.notification_email.created   Timestamp: 2026-04-03 20:39:26.866 Headers: empty
  
consumerrangejservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)-911e8c00-2608-47ee-9885-27f43e7dec0e�Uw�jservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)-911e8c00-2608-47ee-9885-27f43e7dec0e��Eservice@notifier-email-f77fdbf6-dgqfn (github.com/segmentio/kafka-go)/10.131.0.6u0u06*notification.notification_email.created.v1����>*notification.notification_email.created.v1����
Partition: 23   Offset: 19   Key: "notification.user_recipient.getted   Timestamp: 2026-04-03 20:39:48.234 Headers: empty
  
consumerrangejservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)-20c3732b-ff78-4fdb-886c-eb46972e1c4e�U�jservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)-20c3732b-ff78-4fdb-886c-eb46972e1c4e��Eservice@notifier-core-dccd85676-t4pbt (github.com/segmentio/kafka-go)/10.131.0.4u0u03'user_recipient.user_recipient.getted.v1����;'user_recipient.user_recipient.getted.v1����
Partition: 17   Offset: 9   Key: %notification.notification_raw.created   Timestamp: 2026-04-05 22:27:12.415 Headers: empty
  
consumer	rangemservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)-6ccce669-d4b4-4161-ba70-f4091b5d2671�_�םmservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)-6ccce669-d4b4-4161-ba70-f4091b5d2671��Hservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)/10.131.0.16u0u04(notification.notification_raw.created.v1����<(notification.notification_raw.created.v1����
Partition: 38   Offset: 10   Key: $notification.notification_tg.created   Timestamp: 2026-04-05 22:27:12.415 Headers: empty
  
consumer
rangeiservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)-99945cc6-fb88-4a6d-b109-a81fd94b054b�_�מiservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)-99945cc6-fb88-4a6d-b109-a81fd94b054b��Dservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)
/10.114.133.4u0u03'notification.notification_tg.created.v1����;'notification.notification_tg.created.v1����
Partition: 17   Offset: 10   Key: %notification.notification_raw.created   Timestamp: 2026-04-05 22:27:30.628 Headers: empty
  
consumer
rangemservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)-6ccce669-d4b4-4161-ba70-f4091b5d2671�_��mservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)-6ccce669-d4b4-4161-ba70-f4091b5d2671��Hservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)/10.131.0.16u0u04(notification.notification_raw.created.v1����<(notification.notification_raw.created.v1����
Partition: 38   Offset: 11   Key: $notification.notification_tg.created   Timestamp: 2026-04-05 22:27:30.715 Headers: empty
  
consumerrangeiservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)-99945cc6-fb88-4a6d-b109-a81fd94b054b�_��iservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)-99945cc6-fb88-4a6d-b109-a81fd94b054b��Dservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)
/10.114.133.4u0u03'notification.notification_tg.created.v1����;'notification.notification_tg.created.v1����
Partition: 17   Offset: 11   Key: %notification.notification_raw.created   Timestamp: 2026-04-07 14:01:15.675 Headers: empty
  
consumerrangemservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)-09242737-0e95-4c0b-9d3e-cf22f80de946�h?Z�mservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)-09242737-0e95-4c0b-9d3e-cf22f80de946��Hservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)/10.131.0.16u0u04(notification.notification_raw.created.v1����<(notification.notification_raw.created.v1����
Partition: 38   Offset: 12   Key: $notification.notification_tg.created   Timestamp: 2026-04-07 14:01:15.676 Headers: empty
  
consumerrangeiservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)-1c63ddd8-f00e-4ede-a46d-72a840f913fe�h?Z�iservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)-1c63ddd8-f00e-4ede-a46d-72a840f913fe��Dservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)
/10.114.133.4u0u03'notification.notification_tg.created.v1����;'notification.notification_tg.created.v1����
Partition: 38   Offset: 13   Key: $notification.notification_tg.created   Timestamp: 2026-04-07 14:04:33.729 Headers: empty
  
consumer
rangeiservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)-1c63ddd8-f00e-4ede-a46d-72a840f913fe�hB`<iservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)-1c63ddd8-f00e-4ede-a46d-72a840f913fe��Dservice@notifier-tg-59b847bd96-68497 (github.com/segmentio/kafka-go)
/10.114.133.4u0u03'notification.notification_tg.created.v1����;'notification.notification_tg.created.v1����
Partition: 17   Offset: 12   Key: %notification.notification_raw.created   Timestamp: 2026-04-07 14:04:33.731 Headers: empty
  
consumerrangemservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)-09242737-0e95-4c0b-9d3e-cf22f80de946�hB`<mservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)-09242737-0e95-4c0b-9d3e-cf22f80de946��Hservice@notifier-router-688454769c-wdk99 (github.com/segmentio/kafka-go)/10.131.0.16u0u04(notification.notification_raw.created.v1����<(notification.notification_raw.created.v1����