Partition: 19
Offset: 0
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-18 13:58:14.296
Headers: empty
Partition: 19
Offset: 1
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-18 13:58:17.304
Headers: empty
consumer range dservice@import-65fc76b7cf-997xf (github.com/segmentio/kafka-go)-fd4ff298-16e6-44d5-bf14-64c2eeb8f612 ���� dservice@import-65fc76b7cf-997xf (github.com/segmentio/kafka-go)-fd4ff298-16e6-44d5-bf14-64c2eeb8f612�� ?service@import-65fc76b7cf-997xf (github.com/segmentio/kafka-go) /10.131.0.29 _� u0 . "scheduler.import_sources.requested����
����
Partition: 19
Offset: 2
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-18 14:03:02.318
Headers: empty
consumer range dservice@import-65fc76b7cf-zwq9s (github.com/segmentio/kafka-go)-8d10319e-e9e3-4669-8473-396fbed8af30 ��
�, dservice@import-65fc76b7cf-zwq9s (github.com/segmentio/kafka-go)-8d10319e-e9e3-4669-8473-396fbed8af30�� ?service@import-65fc76b7cf-zwq9s (github.com/segmentio/kafka-go) /10.131.0.42 _� u0 . "scheduler.import_sources.requested���� 6 "scheduler.import_sources.requested ����
Partition: 19
Offset: 3
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-18 14:04:38.330
Headers: empty
Partition: 19
Offset: 4
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-18 14:08:29.418
Headers: empty
Partition: 19
Offset: 5
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-19 11:11:27.144
Headers: empty
Partition: 19
Offset: 6
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-19 11:11:30.148
Headers: empty
consumer range dservice@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go)-aabf6fc9-fc56-496f-bf06-1690496b4b49 �ߔ+a dservice@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go)-aabf6fc9-fc56-496f-bf06-1690496b4b49�� ?service@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go) /10.131.0.29 _� u0 . "scheduler.import_sources.requested���� 6 "scheduler.import_sources.requested ����
Partition: 19
Offset: 7
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-21 15:30:57.348
Headers: empty
Partition: 19
Offset: 8
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-21 15:31:07.348
Headers: empty
consumer range dservice@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go)-48576ba3-fccc-42a4-889d-f0f7fe7ae1f8 ��� dservice@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go)-48576ba3-fccc-42a4-889d-f0f7fe7ae1f8�� ?service@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go) /10.131.0.29 _� u0 . "scheduler.import_sources.requested���� 6 "scheduler.import_sources.requested ����
Partition: 19
Offset: 9
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-21 15:31:08.793
Headers: empty
Partition: 19
Offset: 10
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-21 15:31:13.808
Headers: empty
consumer range dservice@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go)-9de7130a-5e32-4fce-9d27-39725240959e ��έ dservice@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go)-9de7130a-5e32-4fce-9d27-39725240959e�� ?service@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go) /10.131.0.29 _� u0 . "scheduler.import_sources.requested���� 6 "scheduler.import_sources.requested ����
Partition: 19
Offset: 11
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-21 15:31:15.252
Headers: empty
Partition: 19
Offset: 12
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-21 15:31:20.269
Headers: empty
consumer range dservice@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go)-72b0324a-db3b-4b03-9adc-8a6dd9e07f44 ����K dservice@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go)-72b0324a-db3b-4b03-9adc-8a6dd9e07f44�� ?service@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go) /10.131.0.29 _� u0 . "scheduler.import_sources.requested���� 6 "scheduler.import_sources.requested ����
Partition: 19
Offset: 13
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-21 15:31:21.814
Headers: empty
Partition: 19
Offset: 14
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-21 15:31:26.913
Headers: empty
consumer range dservice@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go)-1b8271c7-b570-4e00-8bed-9f9b61bae765 ����? dservice@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go)-1b8271c7-b570-4e00-8bed-9f9b61bae765�� ?service@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go) /10.131.0.29 _� u0 . "scheduler.import_sources.requested���� 6 "scheduler.import_sources.requested ����
Partition: 19
Offset: 15
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-22 12:51:54.326
Headers: empty
Partition: 19
Offset: 16
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-22 12:52:08.015
Headers: empty
consumer range dservice@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go)-4d0ac6cc-a37a-4e42-acfb-2ad428a5e196 ��c`� dservice@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go)-4d0ac6cc-a37a-4e42-acfb-2ad428a5e196�� ?service@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go) /10.131.0.29 _� u0 . "scheduler.import_sources.requested���� 6 "scheduler.import_sources.requested ����
Partition: 19
Offset: 17
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-22 12:56:20.037
Headers: empty
consumer range dservice@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go)-4d0ac6cc-a37a-4e42-acfb-2ad428a5e196 ��g9C dservice@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go)-4d0ac6cc-a37a-4e42-acfb-2ad428a5e196�� ?service@import-65fc76b7cf-bgfbp (github.com/segmentio/kafka-go) /10.131.0.29 _� u0 . "scheduler.import_sources.requested���� 6 "scheduler.import_sources.requested ����
Partition: 19
Offset: 18
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-23 11:46:50.061
Headers: empty
Partition: 19
Offset: 19
Key: )import-scheduler.import_sources.requested
Timestamp: 2026-06-23 11:56:15.441
Headers: empty
Partition: 27
Offset: 655
Key: import-import.sources.requested import.sources.requested
Timestamp: 2026-06-25 11:19:26.319
Headers: empty
Partition: 27
Offset: 1195
Key: content-import.sources.created import.sources.created
Timestamp: 2026-06-25 11:19:38.111
Headers: empty
Partition: 18
Offset: 229
Key: 8notifier-core-content.publication.notification_requested *content.publication.notification_requested
Timestamp: 2026-07-10 11:41:18.905
Headers: empty
Partition: 13
Offset: 37
Key: notifier-pwa !notification.delivery.pwa.created
Timestamp: 2026-07-10 11:41:20.409
Headers: empty
Partition: 44
Offset: 650
Key: content-import.news.created import.news.created
Timestamp: 2026-07-10 17:32:02.982
Headers: empty
Partition: 44
Offset: 651
Key: content-import.news.created import.news.created
Timestamp: 2026-07-10 17:42:02.918
Headers: empty
Partition: 14
Offset: 937
Key: import-import.news.requested import.news.requested
Timestamp: 2026-07-10 17:51:33.658
Headers: empty
Partition: 44
Offset: 652
Key: content-import.news.created import.news.created
Timestamp: 2026-07-10 17:52:02.976
Headers: empty
Partition: 18
Offset: 25288
Key: orders-event-group
Timestamp: 2026-07-20 12:00:37.786
Headers: empty
consumer range kservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go)-9a5c63c3-ee9c-4086-920c-6cb2d53d2930 �fI� kservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go)-9a5c63c3-ee9c-4086-920c-6cb2d53d2930�� Fservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go) /10.131.0.20 u0 u0 " order.order.created.v1���� * order.order.created.v1 ����
Partition: 18
Offset: 25289
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-20 12:01:01.184
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-d1002f66-263d-4b6e-afd0-0a6b7df3c9b0 �f�� jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-d1002f66-263d-4b6e-afd0-0a6b7df3c9b0�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49399
Key: content-import.sources.created
Timestamp: 2026-07-20 12:01:04.078
Headers: empty
consumer Y� range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-aab281b1-74b6-4177-a725-770f440b77d5 �f�L dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-aab281b1-74b6-4177-a725-770f440b77d5�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)
/10.114.131.9 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 27
Offset: 49400
Key: import-import.sources.requested
Timestamp: 2026-07-20 12:01:04.079
Headers: empty
consumer bZ range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-a61dd4f3-429f-499f-9116-5944c35e5604 �f�L dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-a61dd4f3-429f-499f-9116-5944c35e5604�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 18
Offset: 25290
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:03:17.615
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-c50fed01-aeea-4a7a-a78c-7fc45964dd9b ���m jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-c50fed01-aeea-4a7a-a78c-7fc45964dd9b�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 18
Offset: 25291
Key: orders-event-group
Timestamp: 2026-07-26 01:03:17.616
Headers: empty
consumer range kservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go)-cdaab0c5-21e3-4da1-95db-afc8bffc8c3b ���n kservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go)-cdaab0c5-21e3-4da1-95db-afc8bffc8c3b�� Fservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go) /10.131.0.20 u0 u0 " order.order.created.v1���� * order.order.created.v1 ����
Partition: 27
Offset: 49401
Key: content-import.sources.created
Timestamp: 2026-07-26 01:03:20.120
Headers: empty
consumer Y� range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-1d18b02a-aee2-4a1d-966d-b55eee2743af ���6 dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-1d18b02a-aee2-4a1d-966d-b55eee2743af�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 27
Offset: 49402
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:03:20.120
Headers: empty
consumer b[ range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-5a85fffe-9e83-425d-aee3-bb481fcaf291 ���7 dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-5a85fffe-9e83-425d-aee3-bb481fcaf291�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 18
Offset: 25292
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:03:20.666
Headers: empty
Partition: 27
Offset: 49403
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:03:23.213
Headers: empty
Partition: 27
Offset: 49404
Key: content-import.sources.created
Timestamp: 2026-07-26 01:03:23.243
Headers: empty
Partition: 18
Offset: 25293
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:03:26.216
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-d00b11a8-c16a-4488-a179-0cb5a631b2d6 ���� jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-d00b11a8-c16a-4488-a179-0cb5a631b2d6�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49405
Key: content-import.sources.created
Timestamp: 2026-07-26 01:03:28.382
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-1f004b4e-0b25-44ee-984c-c7cf823ec902 ����| dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-1f004b4e-0b25-44ee-984c-c7cf823ec902�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 27
Offset: 49406
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:03:28.549
Headers: empty
consumer b] range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-b5f7c87e-376b-4307-8354-2ca032867046 ����# dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-b5f7c87e-376b-4307-8354-2ca032867046�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 18
Offset: 25294
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:03:28.551
Headers: empty
Partition: 27
Offset: 49407
Key: content-import.sources.created
Timestamp: 2026-07-26 01:03:31.190
Headers: empty
Partition: 27
Offset: 49408
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:03:31.191
Headers: empty
Partition: 18
Offset: 25295
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:03:33.908
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-8b7de9b5-ef51-4462-bd10-a9266bff5928 ���� jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-8b7de9b5-ef51-4462-bd10-a9266bff5928�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 18
Offset: 25296
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:03:35.847
Headers: empty
Partition: 27
Offset: 49409
Key: content-import.sources.created
Timestamp: 2026-07-26 01:03:36.809
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-d1831910-517b-4556-ba35-9810ef47d9b2 ����g dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-d1831910-517b-4556-ba35-9810ef47d9b2�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 27
Offset: 49410
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:03:36.810
Headers: empty
consumer b_ range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-067f32d8-7502-4962-8193-5f401dcbaad3 ����h dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-067f32d8-7502-4962-8193-5f401dcbaad3�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 27
Offset: 49411
Key: content-import.sources.created
Timestamp: 2026-07-26 01:03:39.415
Headers: empty
Partition: 27
Offset: 49412
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:03:39.415
Headers: empty
Partition: 18
Offset: 25297
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:03:40.911
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-edada51d-e122-41d1-91cf-c432931f66d9 ����m jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-edada51d-e122-41d1-91cf-c432931f66d9�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 18
Offset: 25298
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:03:43.120
Headers: empty
Partition: 27
Offset: 49413
Key: content-import.sources.created
Timestamp: 2026-07-26 01:03:44.475
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-36a9997b-1034-4c49-a7db-74e8a44d7fe6 ��� Y dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-36a9997b-1034-4c49-a7db-74e8a44d7fe6�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 27
Offset: 49414
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:03:44.475
Headers: empty
consumer ba range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-0fdbebdf-51a2-42d5-a5d2-0d29a22a73e9 ��� Y dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-0fdbebdf-51a2-42d5-a5d2-0d29a22a73e9�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 27
Offset: 49415
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:03:46.945
Headers: empty
Partition: 27
Offset: 49416
Key: content-import.sources.created
Timestamp: 2026-07-26 01:03:47.376
Headers: empty
Partition: 18
Offset: 25299
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:03:48.386
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-11083c41-1eb3-40b1-bba0-5b7e26b64f7f ���� jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-11083c41-1eb3-40b1-bba0-5b7e26b64f7f�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 18
Offset: 25300
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:03:50.890
Headers: empty
Partition: 27
Offset: 49417
Key: content-import.sources.created
Timestamp: 2026-07-26 01:03:52.759
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-66b8f033-5936-48cf-8702-ac8f29c1bf98 ���+� dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-66b8f033-5936-48cf-8702-ac8f29c1bf98�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 27
Offset: 49418
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:03:53.070
Headers: empty
consumer bc range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-2ca41da5-3d5e-49a1-9dbe-ce18b3f5c6e0 ���,� dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-2ca41da5-3d5e-49a1-9dbe-ce18b3f5c6e0�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 18
Offset: 25301
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:03:56.628
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-710f1f90-f4d3-4476-9cd6-90251de33c85 ���:� jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-710f1f90-f4d3-4476-9cd6-90251de33c85�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49419
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:03:58.701
Headers: empty
Partition: 27
Offset: 49420
Key: content-import.sources.created
Timestamp: 2026-07-26 01:03:59.041
Headers: empty
Partition: 18
Offset: 25302
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:04:02.307
Headers: empty
Partition: 27
Offset: 49421
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:04:04.925
Headers: empty
consumer be range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-f7b80e5e-c30b-42b6-a017-5329b6cd224c ���[; dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-f7b80e5e-c30b-42b6-a017-5329b6cd224c�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 27
Offset: 49422
Key: content-import.sources.created
Timestamp: 2026-07-26 01:04:07.306
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-e59e6cde-aac8-4a57-85be-228f18e854bf ���d� dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-e59e6cde-aac8-4a57-85be-228f18e854bf�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 18
Offset: 25303
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:04:09.533
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-8bc3d67e-3cae-4b5f-9017-65070302e126 ���m; jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-8bc3d67e-3cae-4b5f-9017-65070302e126�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49423
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:04:12.492
Headers: empty
Partition: 27
Offset: 49424
Key: content-import.sources.created
Timestamp: 2026-07-26 01:04:18.957
Headers: empty
Partition: 18
Offset: 25304
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:04:19.002
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-8bc3d67e-3cae-4b5f-9017-65070302e126 ���9 jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-8bc3d67e-3cae-4b5f-9017-65070302e126�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49425
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:04:22.003
Headers: empty
consumer bg range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-c54ab36e-a258-4fb2-bbd9-48e922682059 ���� dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-c54ab36e-a258-4fb2-bbd9-48e922682059�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 18
Offset: 25305
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:04:22.585
Headers: empty
Partition: 27
Offset: 49426
Key: content-import.sources.created
Timestamp: 2026-07-26 01:04:27.532
Headers: empty
consumer Z
range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-6a06ec7b-2eb9-45dc-8b7e-bb6e5c5d279d ��� dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-6a06ec7b-2eb9-45dc-8b7e-bb6e5c5d279d�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 18
Offset: 25306
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:04:31.609
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-2c1df6a8-c4ff-43af-a2d5-48340050e49c ����w jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-2c1df6a8-c4ff-43af-a2d5-48340050e49c�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49427
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:04:33.096
Headers: empty
Partition: 27
Offset: 49428
Key: content-import.sources.created
Timestamp: 2026-07-26 01:04:35.401
Headers: empty
Partition: 18
Offset: 25307
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:04:38.140
Headers: empty
Partition: 27
Offset: 49429
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:04:41.143
Headers: empty
consumer bi range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-149f09bb-9487-448e-b6f8-7c9c764e080e ���� dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-149f09bb-9487-448e-b6f8-7c9c764e080e�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 27
Offset: 49430
Key: content-import.sources.created
Timestamp: 2026-07-26 01:04:43.630
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-44e6155d-f145-412d-9421-9ce535e7723a ����l dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-44e6155d-f145-412d-9421-9ce535e7723a�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 18
Offset: 25308
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:04:48.729
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-0805bdfa-ea0b-4c49-8eab-29e8fa09362c ���W jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-0805bdfa-ea0b-4c49-8eab-29e8fa09362c�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49431
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:04:52.242
Headers: empty
Partition: 27
Offset: 49432
Key: content-import.sources.created
Timestamp: 2026-07-26 01:04:55.451
Headers: empty
Partition: 18
Offset: 25309
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:04:58.775
Headers: empty
Partition: 27
Offset: 49433
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:05:00.761
Headers: empty
consumer bk range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-2a1c9ce1-a2f0-430e-8ef8-1dceebd8d48c ���5W dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-2a1c9ce1-a2f0-430e-8ef8-1dceebd8d48c�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 27
Offset: 49434
Key: content-import.sources.created
Timestamp: 2026-07-26 01:05:02.065
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-9ce6747a-1492-4143-865a-a2e990371780 ���:o dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-9ce6747a-1492-4143-865a-a2e990371780�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 18
Offset: 25310
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:05:05.032
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-36ce4880-039f-4fce-90c0-a5784e7f47b9 ���F jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-36ce4880-039f-4fce-90c0-a5784e7f47b9�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49435
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:05:16.497
Headers: empty
Partition: 27
Offset: 49436
Key: content-import.sources.created
Timestamp: 2026-07-26 01:05:17.002
Headers: empty
Partition: 18
Offset: 25311
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:05:19.868
Headers: empty
Partition: 27
Offset: 49437
Key: content-import.sources.created
Timestamp: 2026-07-26 01:05:23.921
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-27f335c6-70fd-41f9-973a-d2511046a6c1 ���� dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-27f335c6-70fd-41f9-973a-d2511046a6c1�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 27
Offset: 49438
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:05:24.459
Headers: empty
consumer bm range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-ad231449-d10b-4680-8d08-d4a63dbaf92c ����� dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-ad231449-d10b-4680-8d08-d4a63dbaf92c�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 18
Offset: 25312
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:05:26.800
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-e0770f8b-3b35-4877-a792-0314a257281a ���� jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-e0770f8b-3b35-4877-a792-0314a257281a�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49439
Key: content-import.sources.created
Timestamp: 2026-07-26 01:05:35.931
Headers: empty
Partition: 27
Offset: 49440
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:05:37.796
Headers: empty
Partition: 18
Offset: 25313
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:05:41.969
Headers: empty
Partition: 27
Offset: 49441
Key: content-import.sources.created
Timestamp: 2026-07-26 01:05:44.938
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-2601df5b-5cbe-493d-98b3-297561b34bf9 ����� dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-2601df5b-5cbe-493d-98b3-297561b34bf9�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 27
Offset: 49442
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:05:47.671
Headers: empty
consumer bo range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-f5e49f51-79b6-4197-a99d-ee8d0fb03060 ���� dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-f5e49f51-79b6-4197-a99d-ee8d0fb03060�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 18
Offset: 25314
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:05:50.438
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-769fda9b-be63-4a8a-9506-74a0626cee53 ����d jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-769fda9b-be63-4a8a-9506-74a0626cee53�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49443
Key: content-import.sources.created
Timestamp: 2026-07-26 01:05:59.136
Headers: empty
Partition: 27
Offset: 49444
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:06:00.096
Headers: empty
Partition: 18
Offset: 25315
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:06:06.433
Headers: empty
Partition: 27
Offset: 49445
Key: content-import.sources.created
Timestamp: 2026-07-26 01:06:07.735
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-4826c1a1-85d3-4b97-9e59-9cb054bc36ef ���:� dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-4826c1a1-85d3-4b97-9e59-9cb054bc36ef�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 27
Offset: 49446
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:06:12.976
Headers: empty
consumer bq range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-d267fc69-33b6-41f6-a080-f7e59b42e27b ���On dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-d267fc69-33b6-41f6-a080-f7e59b42e27b�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 18
Offset: 25316
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:06:15.382
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-2aabf219-a0cb-4cc5-a2b2-202046825027 ���X� jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-2aabf219-a0cb-4cc5-a2b2-202046825027�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49447
Key: content-import.sources.created
Timestamp: 2026-07-26 01:06:19.140
Headers: empty
Partition: 27
Offset: 49448
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:06:23.759
Headers: empty
Partition: 18
Offset: 25317
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:06:25.604
Headers: empty
Partition: 27
Offset: 49449
Key: content-import.sources.created
Timestamp: 2026-07-26 01:06:29.037
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-dd345240-00f2-4579-924a-1c625fdb0d9c ����, dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-dd345240-00f2-4579-924a-1c625fdb0d9c�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 18
Offset: 25318
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:06:32.109
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-d7a6732b-4b54-4a6d-8185-501e1c8df639 ����+ jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-d7a6732b-4b54-4a6d-8185-501e1c8df639�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49450
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:06:32.124
Headers: empty
consumer bs range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-c89f599b-3bc4-44c9-bd75-0bcc43ee789c ����: dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-c89f599b-3bc4-44c9-bd75-0bcc43ee789c�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 27
Offset: 49451
Key: content-import.sources.created
Timestamp: 2026-07-26 01:06:41.168
Headers: empty
Partition: 18
Offset: 25319
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:06:47.433
Headers: empty
Partition: 27
Offset: 49452
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:06:47.515
Headers: empty
Partition: 27
Offset: 49453
Key: content-import.sources.created
Timestamp: 2026-07-26 01:06:51.912
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-469425d8-37df-47e4-a799-b3540f7544f4 ���� dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-469425d8-37df-47e4-a799-b3540f7544f4�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 27
Offset: 49454
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:06:58.449
Headers: empty
consumer bu range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-7ff685ce-2328-4222-b5b5-67cf7196a950 ��� dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-7ff685ce-2328-4222-b5b5-67cf7196a950�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 18
Offset: 25320
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:07:00.138
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-c8f6cb18-6433-4aaa-9838-e08c194958fe ���� jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-c8f6cb18-6433-4aaa-9838-e08c194958fe�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49455
Key: content-import.sources.created
Timestamp: 2026-07-26 01:07:06.135
Headers: empty
Partition: 27
Offset: 49456
Key: content-import.sources.created
Timestamp: 2026-07-26 01:07:15.523
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-7a141bd1-2db1-470d-b627-d5924cdba75a ���C� dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-7a141bd1-2db1-470d-b627-d5924cdba75a�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 18
Offset: 25321
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:07:16.004
Headers: empty
Partition: 27
Offset: 49457
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:07:17.743
Headers: empty
Partition: 18
Offset: 25322
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:07:23.616
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-b4920c80-0ff1-4a97-bc86-a72ef51da039 ���c^ jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-b4920c80-0ff1-4a97-bc86-a72ef51da039�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49458
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:07:26.252
Headers: empty
consumer bw range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-a6a5b920-de43-476e-a65c-4923e4c30047 ���m� dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-a6a5b920-de43-476e-a65c-4923e4c30047�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 27
Offset: 49459
Key: content-import.sources.created
Timestamp: 2026-07-26 01:07:27.129
Headers: empty
Partition: 18
Offset: 25323
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:08:06.376
Headers: empty
Partition: 18
Offset: 25324
Key: orders-event-group
Timestamp: 2026-07-26 01:08:06.378
Headers: empty
Partition: 27
Offset: 49460
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:08:06.380
Headers: empty
Partition: 27
Offset: 49461
Key: content-import.sources.created
Timestamp: 2026-07-26 01:09:27.645
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-b27a44ea-4b3b-494d-898c-ce15fb28695a ���G� dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-b27a44ea-4b3b-494d-898c-ce15fb28695a�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)
/10.114.131.9 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 18
Offset: 25325
Key: orders-event-group
Timestamp: 2026-07-26 01:09:30.958
Headers: empty
consumer range kservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go)-5ae90624-9c71-4568-8aa7-8f5a5ad62bd0 ���T� kservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go)-5ae90624-9c71-4568-8aa7-8f5a5ad62bd0�� Fservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go) /10.131.0.20 u0 u0 " order.order.created.v1���� * order.order.created.v1 ����
Partition: 27
Offset: 49462
Key: import-import.sources.requested
Timestamp: 2026-07-26 01:09:47.050
Headers: empty
consumer by range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-6b46eda5-f49a-4ee6-bee6-bd7da9f95f97 ����� dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-6b46eda5-f49a-4ee6-bee6-bd7da9f95f97�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 18
Offset: 25326
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-07-26 01:09:47.055
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-afaa92e8-0eb4-46fe-8075-ba23d924b4f9 ����� jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-afaa92e8-0eb4-46fe-8075-ba23d924b4f9�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 38
Offset: 32
Key: $notification.notification_tg.created
Timestamp: 2026-07-26 01:09:54.878
Headers: empty
consumer range iservice@notifier-tg-59b847bd96-mgk5s (github.com/segmentio/kafka-go)-1372905a-5cc8-41ff-87f1-3209c7633d25 ����< iservice@notifier-tg-59b847bd96-mgk5s (github.com/segmentio/kafka-go)-1372905a-5cc8-41ff-87f1-3209c7633d25�� Dservice@notifier-tg-59b847bd96-mgk5s (github.com/segmentio/kafka-go) /10.114.131.11 u0 u0 3 'notification.notification_tg.created.v1���� ; 'notification.notification_tg.created.v1 ����
Partition: 13
Offset: 57
Key: notifier-pwa
Timestamp: 2026-07-29 21:43:57.207
Headers: empty
consumer 3 range oservice@notifier-pwa-push-697c6455c5-sz2vq (github.com/segmentio/kafka-go)-fed38cef-c02d-4a1d-8abe-ecf44b199c39 ��Ւ oservice@notifier-pwa-push-697c6455c5-sz2vq (github.com/segmentio/kafka-go)-fed38cef-c02d-4a1d-8abe-ecf44b199c39�� Jservice@notifier-pwa-push-697c6455c5-sz2vq (github.com/segmentio/kafka-go) /10.131.0.9 _� u0 - !notification.delivery.pwa.created���� 5 !notification.delivery.pwa.created ����
Partition: 17
Offset: 50
Key: %notification.notification_raw.created
Timestamp: 2026-07-29 21:43:57.207
Headers: empty
consumer range mservice@notifier-router-688454769c-jsvhf (github.com/segmentio/kafka-go)-135e1295-76e3-4863-8b0e-a51137d6446b ��Ւ mservice@notifier-router-688454769c-jsvhf (github.com/segmentio/kafka-go)-135e1295-76e3-4863-8b0e-a51137d6446b�� Hservice@notifier-router-688454769c-jsvhf (github.com/segmentio/kafka-go) /10.131.0.20 u0 u0 4 (notification.notification_raw.created.v1���� < (notification.notification_raw.created.v1 ����
Partition: 43
Offset: 52
Key: 'notification.notification_email.created
Timestamp: 2026-07-29 21:43:57.207
Headers: empty
consumer range jservice@notifier-email-f77fdbf6-kxs2k (github.com/segmentio/kafka-go)-9373db70-68b0-48ef-9151-afebdcf5624a ��Ւ jservice@notifier-email-f77fdbf6-kxs2k (github.com/segmentio/kafka-go)-9373db70-68b0-48ef-9151-afebdcf5624a�� Eservice@notifier-email-f77fdbf6-kxs2k (github.com/segmentio/kafka-go) /10.131.0.40 u0 u0 6 *notification.notification_email.created.v1���� > *notification.notification_email.created.v1 ����
Partition: 38
Offset: 33
Key: $notification.notification_tg.created
Timestamp: 2026-08-02 00:43:13.703
Headers: empty
consumer ! range iservice@notifier-tg-59b847bd96-mgk5s (github.com/segmentio/kafka-go)-715c0d35-3217-4eaa-9ced-9e9fb94c66c8 ���ǥ iservice@notifier-tg-59b847bd96-mgk5s (github.com/segmentio/kafka-go)-715c0d35-3217-4eaa-9ced-9e9fb94c66c8�� Dservice@notifier-tg-59b847bd96-mgk5s (github.com/segmentio/kafka-go) /10.131.0.40 u0 u0 3 'notification.notification_tg.created.v1���� ; 'notification.notification_tg.created.v1 ����
Partition: 18
Offset: 25327
Key: orders-event-group
Timestamp: 2026-08-02 00:43:13.751
Headers: empty
consumer ! range kservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go)-f3c77ed7-965d-4d24-ad43-da52cb989f8e ����� kservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go)-f3c77ed7-965d-4d24-ad43-da52cb989f8e�� Fservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go) /10.131.0.20 u0 u0 " order.order.created.v1���� * order.order.created.v1 ����
Partition: 18
Offset: 25328
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-08-02 00:43:13.751
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-98719d45-60ef-40bf-98e6-caddf12d37d0 ����� jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-98719d45-60ef-40bf-98e6-caddf12d37d0�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 27
Offset: 49463
Key: import-import.sources.requested
Timestamp: 2026-08-02 00:43:13.759
Headers: empty
consumer bz range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-45660e9d-4ae0-43cd-acbb-2dec10ed7507 ����� dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-45660e9d-4ae0-43cd-acbb-2dec10ed7507�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.114.130.101 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 27
Offset: 49464
Key: content-import.sources.created
Timestamp: 2026-08-02 00:43:13.760
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-af3a160c-5236-4a56-b874-1e6b2bc84ea9 ����� dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-af3a160c-5236-4a56-b874-1e6b2bc84ea9�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 18
Offset: 25329
Key: 8notifier-core-content.publication.notification_requested
Timestamp: 2026-08-02 00:43:58.836
Headers: empty
consumer b� range jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-98719d45-60ef-40bf-98e6-caddf12d37d0 ���w� jservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go)-98719d45-60ef-40bf-98e6-caddf12d37d0�� Eservice@notifier-core-5cbb8f75f-vtdws (github.com/segmentio/kafka-go) /10.131.0.20 _� u0 6 *content.publication.notification_requested���� > *content.publication.notification_requested ����
Partition: 38
Offset: 34
Key: $notification.notification_tg.created
Timestamp: 2026-08-02 00:43:58.905
Headers: empty
consumer " range iservice@notifier-tg-59b847bd96-mgk5s (github.com/segmentio/kafka-go)-715c0d35-3217-4eaa-9ced-9e9fb94c66c8 ���w� iservice@notifier-tg-59b847bd96-mgk5s (github.com/segmentio/kafka-go)-715c0d35-3217-4eaa-9ced-9e9fb94c66c8�� Dservice@notifier-tg-59b847bd96-mgk5s (github.com/segmentio/kafka-go) /10.131.0.40 u0 u0 3 'notification.notification_tg.created.v1���� ; 'notification.notification_tg.created.v1 ����
Partition: 27
Offset: 49465
Key: content-import.sources.created
Timestamp: 2026-08-02 00:43:59.008
Headers: empty
consumer Z range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-af3a160c-5236-4a56-b874-1e6b2bc84ea9 ���x� dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-af3a160c-5236-4a56-b874-1e6b2bc84ea9�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go) /10.131.0.40 _� u0 " import.sources.created���� * import.sources.created ����
Partition: 27
Offset: 49466
Key: import-import.sources.requested
Timestamp: 2026-08-02 00:43:59.104
Headers: empty
consumer b{ range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-45660e9d-4ae0-43cd-acbb-2dec10ed7507 ���x� dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-45660e9d-4ae0-43cd-acbb-2dec10ed7507�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.114.130.101 _� u0 $ import.sources.requested���� , import.sources.requested ����
Partition: 14
Offset: 1274
Key: import-import.news.requested
Timestamp: 2026-08-02 00:43:59.109
Headers: empty
consumer � range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-4ffbbe00-a2be-42b6-a550-f183b51bcbb2 ���y dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-4ffbbe00-a2be-42b6-a550-f183b51bcbb2�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.114.130.101 _� u0 ! import.news.requested���� ) import.news.requested ����
Partition: 18
Offset: 25330
Key: orders-event-group
Timestamp: 2026-08-02 00:43:59.208
Headers: empty
consumer " range kservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go)-f3c77ed7-965d-4d24-ad43-da52cb989f8e ���y kservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go)-f3c77ed7-965d-4d24-ad43-da52cb989f8e�� Fservice@user-recipient-b486d4f65-m9bvx (github.com/segmentio/kafka-go) /10.131.0.20 u0 u0 " order.order.created.v1���� * order.order.created.v1 ����
Partition: 44
Offset: 689
Key: content-import.news.created
Timestamp: 2026-08-02 00:44:06.313
Headers: empty
consumer A range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-bee7a420-5617-4a58-9a1c-56c54f64fc68 ���' dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-bee7a420-5617-4a58-9a1c-56c54f64fc68�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)
/10.114.131.9 _� u0 import.news.created���� / import.news.created ����
Partition: 44
Offset: 690
Key: content-import.news.created
Timestamp: 2026-08-02 17:51:36.285
Headers: empty
Partition: 44
Offset: 691
Key: content-import.news.created
Timestamp: 2026-08-02 17:51:46.222
Headers: empty
consumer C range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-c892ce47-4425-4d9a-bb1f-9679df94f95e �Úp, dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-c892ce47-4425-4d9a-bb1f-9679df94f95e�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)
/10.114.131.9 _� u0 import.news.created���� / import.news.created ����
Partition: 13
Offset: 58
Key: notifier-pwa
Timestamp: 2026-08-02 17:52:11.320
Headers: empty
consumer 4 range oservice@notifier-pwa-push-697c6455c5-sz2vq (github.com/segmentio/kafka-go)-94f9ab3b-5551-4b1a-9583-a67f963f908c ��6 oservice@notifier-pwa-push-697c6455c5-sz2vq (github.com/segmentio/kafka-go)-94f9ab3b-5551-4b1a-9583-a67f963f908c�� Jservice@notifier-pwa-push-697c6455c5-sz2vq (github.com/segmentio/kafka-go) /10.131.0.9 _� u0 - !notification.delivery.pwa.created���� 5 !notification.delivery.pwa.created ����
Partition: 17
Offset: 51
Key: %notification.notification_raw.created
Timestamp: 2026-08-02 17:52:11.321
Headers: empty
consumer range mservice@notifier-router-688454769c-jsvhf (github.com/segmentio/kafka-go)-012c0f4a-f8b6-42f5-8235-424baf4d7486 ��7 mservice@notifier-router-688454769c-jsvhf (github.com/segmentio/kafka-go)-012c0f4a-f8b6-42f5-8235-424baf4d7486�� Hservice@notifier-router-688454769c-jsvhf (github.com/segmentio/kafka-go) /10.131.0.20 u0 u0 4 (notification.notification_raw.created.v1���� < (notification.notification_raw.created.v1 ����
Partition: 43
Offset: 53
Key: 'notification.notification_email.created
Timestamp: 2026-08-02 17:52:11.409
Headers: empty
consumer range jservice@notifier-email-f77fdbf6-kxs2k (github.com/segmentio/kafka-go)-0aa3c354-2931-473f-b0b8-6200ff77d0f5 �Úҏ jservice@notifier-email-f77fdbf6-kxs2k (github.com/segmentio/kafka-go)-0aa3c354-2931-473f-b0b8-6200ff77d0f5�� Eservice@notifier-email-f77fdbf6-kxs2k (github.com/segmentio/kafka-go) /10.114.131.10 u0 u0 6 *notification.notification_email.created.v1���� > *notification.notification_email.created.v1 ����
Partition: 17
Offset: 52
Key: %notification.notification_raw.created
Timestamp: 2026-08-02 17:57:02.859
Headers: empty
consumer range mservice@notifier-router-688454769c-jsvhf (github.com/segmentio/kafka-go)-85e5c554-d7fc-490a-866f-1de6538f78ef �ßE mservice@notifier-router-688454769c-jsvhf (github.com/segmentio/kafka-go)-85e5c554-d7fc-490a-866f-1de6538f78ef�� Hservice@notifier-router-688454769c-jsvhf (github.com/segmentio/kafka-go) /10.131.0.20 u0 u0 4 (notification.notification_raw.created.v1���� < (notification.notification_raw.created.v1 ����
Partition: 13
Offset: 59
Key: notifier-pwa
Timestamp: 2026-08-02 17:57:02.861
Headers: empty
consumer 5 range oservice@notifier-pwa-push-697c6455c5-sz2vq (github.com/segmentio/kafka-go)-40753c75-dca9-40e9-873c-985f28a4b747 �ßE
oservice@notifier-pwa-push-697c6455c5-sz2vq (github.com/segmentio/kafka-go)-40753c75-dca9-40e9-873c-985f28a4b747�� Jservice@notifier-pwa-push-697c6455c5-sz2vq (github.com/segmentio/kafka-go) /10.131.0.9 _� u0 - !notification.delivery.pwa.created���� 5 !notification.delivery.pwa.created ����
Partition: 43
Offset: 54
Key: 'notification.notification_email.created
Timestamp: 2026-08-02 17:57:02.861
Headers: empty
consumer range jservice@notifier-email-f77fdbf6-kxs2k (github.com/segmentio/kafka-go)-14601dbd-9a9e-40cd-9a9f-e86dd6a1dd9b �ßE jservice@notifier-email-f77fdbf6-kxs2k (github.com/segmentio/kafka-go)-14601dbd-9a9e-40cd-9a9f-e86dd6a1dd9b�� Eservice@notifier-email-f77fdbf6-kxs2k (github.com/segmentio/kafka-go) /10.131.0.40 u0 u0 6 *notification.notification_email.created.v1���� > *notification.notification_email.created.v1 ����
Partition: 14
Offset: 1275
Key: import-import.news.requested
Timestamp: 2026-08-04 17:46:03.290
Headers: empty
Partition: 44
Offset: 692
Key: content-import.news.created
Timestamp: 2026-08-04 17:46:06.424
Headers: empty
Partition: 14
Offset: 1276
Key: import-import.news.requested
Timestamp: 2026-08-04 17:46:13.298
Headers: empty
consumer � range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-c1ec4600-424e-4303-b850-01402b9bffc7 ���� dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-c1ec4600-424e-4303-b850-01402b9bffc7�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 ! import.news.requested���� ) import.news.requested ����
Partition: 14
Offset: 1277
Key: import-import.news.requested
Timestamp: 2026-08-04 17:46:14.737
Headers: empty
Partition: 44
Offset: 693
Key: content-import.news.created
Timestamp: 2026-08-04 17:46:16.430
Headers: empty
consumer E range dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-2e9c50c6-cdc2-4805-bd52-70417e784ada ��� � dservice@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)-2e9c50c6-cdc2-4805-bd52-70417e784ada�� ?service@content-d67796996-bx9b2 (github.com/segmentio/kafka-go)
/10.114.131.9 _� u0 import.news.created���� / import.news.created ����
Partition: 14
Offset: 1278
Key: import-import.news.requested
Timestamp: 2026-08-04 17:46:19.752
Headers: empty
consumer � range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-daf9b4f8-e282-4ae6-8dc4-0237c252b4b9 ���,� dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-daf9b4f8-e282-4ae6-8dc4-0237c252b4b9�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 ! import.news.requested���� ) import.news.requested ����
Partition: 14
Offset: 1279
Key: import-import.news.requested
Timestamp: 2026-08-04 17:46:21.190
Headers: empty
Partition: 14
Offset: 1280
Key: import-import.news.requested
Timestamp: 2026-08-04 17:46:26.255
Headers: empty
consumer � range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-bb458101-63bd-4eca-bf09-4b4f7ea51457 ���FM dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-bb458101-63bd-4eca-bf09-4b4f7ea51457�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 ! import.news.requested���� ) import.news.requested ����
Partition: 14
Offset: 1281
Key: import-import.news.requested
Timestamp: 2026-08-04 17:46:27.690
Headers: empty
Partition: 14
Offset: 1282
Key: import-import.news.requested
Timestamp: 2026-08-04 17:46:32.706
Headers: empty
consumer � range dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-234ad87b-4364-476b-899e-482010bad9eb ���_� dservice@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go)-234ad87b-4364-476b-899e-482010bad9eb�� ?service@import-5dbd989884-sxfgx (github.com/segmentio/kafka-go) /10.130.0.20 _� u0 ! import.news.requested���� ) import.news.requested ����
