Kafdrop: Topic: __consumer_offsets: Messages

Partition: 23 Offset: 0 Key: "notification.user_recipient.getted Timestamp: 2026-01-31 23:19:26.928 Headers: empty

�����Z��

Partition: 17 Offset: 0 Key: %notification.notification_raw.created Timestamp: 2026-01-31 23:19:27.015 Headers: empty

�����Z�&

Partition: 18 Offset: 0 Key: orders-event-group Timestamp: 2026-01-31 23:19:27.715 Headers: empty

�����Z��

Partition: 38 Offset: 0 Key: $notification.notification_tg.created Timestamp: 2026-01-31 23:19:29.233 Headers: empty

�����Z��

Partition: 43 Offset: 0 Key: 'notification.notification_email.created Timestamp: 2026-01-31 23:19:29.234 Headers: empty

�����Z��

Partition: 23 Offset: 1 Key: "notification.user_recipient.getted Timestamp: 2026-01-31 23:19:29.939 Headers: empty

consumerrangejservice@notifier-core-dccd85676-5h82h (github.com/segmentio/kafka-go)-2a69eaef-1ce2-40f9-b8aa-64dfbedec416�Z��jservice@notifier-core-dccd85676-5h82h (github.com/segmentio/kafka-go)-2a69eaef-1ce2-40f9-b8aa-64dfbedec416��Eservice@notifier-core-dccd85676-5h82h (github.com/segmentio/kafka-go)
/10.114.128.3u0u03'user_recipient.user_recipient.getted.v1����
����

Partition: 17 Offset: 1 Key: %notification.notification_raw.created Timestamp: 2026-01-31 23:19:30.025 Headers: empty

consumerrangemservice@notifier-router-688454769c-ts247 (github.com/segmentio/kafka-go)-c6e79464-3429-4d70-aae3-1065acf7ce55�Z��mservice@notifier-router-688454769c-ts247 (github.com/segmentio/kafka-go)-c6e79464-3429-4d70-aae3-1065acf7ce55��Hservice@notifier-router-688454769c-ts247 (github.com/segmentio/kafka-go)/10.114.131.10u0u04(notification.notification_raw.created.v1����
����

Partition: 18 Offset: 1 Key: orders-event-group Timestamp: 2026-01-31 23:19:30.721 Headers: empty

consumerrangekservice@user-recipient-b486d4f65-6c86m (github.com/segmentio/kafka-go)-95b37191-6939-4c30-8437-e1e39fcedc2a�Z��kservice@user-recipient-b486d4f65-6c86m (github.com/segmentio/kafka-go)-95b37191-6939-4c30-8437-e1e39fcedc2a��Fservice@user-recipient-b486d4f65-6c86m (github.com/segmentio/kafka-go)/10.131.0.27u0u0"order.order.created.v1����
����

Partition: 38 Offset: 1 Key: $notification.notification_tg.created Timestamp: 2026-01-31 23:19:32.237 Headers: empty

consumerrangeiservice@notifier-tg-59b847bd96-lkpcq (github.com/segmentio/kafka-go)-10be9a0f-3896-4ed2-94cb-a2086b9dc971�Z��iservice@notifier-tg-59b847bd96-lkpcq (github.com/segmentio/kafka-go)-10be9a0f-3896-4ed2-94cb-a2086b9dc971��Dservice@notifier-tg-59b847bd96-lkpcq (github.com/segmentio/kafka-go)/10.131.0.27u0u03'notification.notification_tg.created.v1����
����

Partition: 43 Offset: 1 Key: 'notification.notification_email.created Timestamp: 2026-01-31 23:19:32.237 Headers: empty

consumerrangejservice@notifier-email-f77fdbf6-qj68m (github.com/segmentio/kafka-go)-f65132f8-e027-4c79-af34-877496e6e869�Z��jservice@notifier-email-f77fdbf6-qj68m (github.com/segmentio/kafka-go)-f65132f8-e027-4c79-af34-877496e6e869��Eservice@notifier-email-f77fdbf6-qj68m (github.com/segmentio/kafka-go)/10.131.0.27u0u06*notification.notification_email.created.v1����
����

Partition: 43 Offset: 2 Key: 'notification.notification_email.created Timestamp: 2026-02-04 19:58:21.015 Headers: empty

consumerrangejservice@notifier-email-f77fdbf6-qj68m (github.com/segmentio/kafka-go)-7b457886-bdde-4db9-b6a4-f058b7958c4a�*;�Ujservice@notifier-email-f77fdbf6-qj68m (github.com/segmentio/kafka-go)-7b457886-bdde-4db9-b6a4-f058b7958c4a��Eservice@notifier-email-f77fdbf6-qj68m (github.com/segmentio/kafka-go)/10.131.0.27u0u06*notification.notification_email.created.v1����>*notification.notification_email.created.v1����

Partition: 23 Offset: 2 Key: "notification.user_recipient.getted Timestamp: 2026-02-04 19:58:21.020 Headers: empty

consumerrangejservice@notifier-core-dccd85676-5h82h (github.com/segmentio/kafka-go)-b8cf2338-f389-498d-b693-bdfcb09d3210�*;�Wjservice@notifier-core-dccd85676-5h82h (github.com/segmentio/kafka-go)-b8cf2338-f389-498d-b693-bdfcb09d3210��Eservice@notifier-core-dccd85676-5h82h (github.com/segmentio/kafka-go)/10.131.0.30u0u03'user_recipient.user_recipient.getted.v1����;'user_recipient.user_recipient.getted.v1����

Partition: 38 Offset: 2 Key: $notification.notification_tg.created Timestamp: 2026-02-04 19:58:21.109 Headers: empty

consumerrangeiservice@notifier-tg-59b847bd96-lkpcq (github.com/segmentio/kafka-go)-9a85b33e-b000-46ce-857a-08df8a0c28a8�*;��iservice@notifier-tg-59b847bd96-lkpcq (github.com/segmentio/kafka-go)-9a85b33e-b000-46ce-857a-08df8a0c28a8��Dservice@notifier-tg-59b847bd96-lkpcq (github.com/segmentio/kafka-go)/10.131.0.27u0u03'notification.notification_tg.created.v1����;'notification.notification_tg.created.v1����

Partition: 43 Offset: 3 Key: 'notification.notification_email.created Timestamp: 2026-02-04 20:02:42.092 Headers: empty

consumerrangejservice@notifier-email-f77fdbf6-qj68m (github.com/segmentio/kafka-go)-7b457886-bdde-4db9-b6a4-f058b7958c4a�*?�(jservice@notifier-email-f77fdbf6-qj68m (github.com/segmentio/kafka-go)-7b457886-bdde-4db9-b6a4-f058b7958c4a��Eservice@notifier-email-f77fdbf6-qj68m (github.com/segmentio/kafka-go)/10.131.0.27u0u06*notification.notification_email.created.v1����>*notification.notification_email.created.v1����

Partition: 23 Offset: 3 Key: "notification.user_recipient.getted Timestamp: 2026-02-04 20:02:42.093 Headers: empty

consumerrangejservice@notifier-core-dccd85676-5h82h (github.com/segmentio/kafka-go)-b8cf2338-f389-498d-b693-bdfcb09d3210�*?�(jservice@notifier-core-dccd85676-5h82h (github.com/segmentio/kafka-go)-b8cf2338-f389-498d-b693-bdfcb09d3210��Eservice@notifier-core-dccd85676-5h82h (github.com/segmentio/kafka-go)/10.131.0.30u0u03'user_recipient.user_recipient.getted.v1����;'user_recipient.user_recipient.getted.v1����

Partition: 38 Offset: 3 Key: $notification.notification_tg.created Timestamp: 2026-02-04 20:02:42.215 Headers: empty

consumerrangeiservice@notifier-tg-59b847bd96-lkpcq (github.com/segmentio/kafka-go)-9a85b33e-b000-46ce-857a-08df8a0c28a8�*?��iservice@notifier-tg-59b847bd96-lkpcq (github.com/segmentio/kafka-go)-9a85b33e-b000-46ce-857a-08df8a0c28a8��Dservice@notifier-tg-59b847bd96-lkpcq (github.com/segmentio/kafka-go)/10.131.0.27u0u03'notification.notification_tg.created.v1����;'notification.notification_tg.created.v1����

Kafdrop

Topic Messages: __consumer_offsets