Skip to content

Instantly share code, notes, and snippets.

@PhanDuc

PhanDuc/consumer.txt

Last active September 8, 2021 08:47
Show Gist options
  • Save PhanDuc/a29e3c5f15b78a9060c9722cb191e081 to your computer and use it in GitHub Desktop.
Save PhanDuc/a29e3c5f15b78a9060c9722cb191e081 to your computer and use it in GitHub Desktop.
Download ZIP
Consumer format from kafka
Raw
consumer.txt
ConsumerRecord(topic='ai-integrator-video', partition=0, offset=127, timestamp=1631076816929, timestamp_type=0, key=b'17812', value=b'{"request_id": 17812, "request_type": "video_url", "log_id": 15093, "category_id": 1, "object_id": 1, "field_name": "VideoUrl", "field_value": "https://fbang-web-assets.s3.ap-southeast-1.amazonaws.com/common/ELDEN+RING+-+Official+Gameplay+Reveal.mp4"}', checksum=None, serialized_key_size=5, serialized_value_size=251, headers=())
ConsumerRecord(topic='ai-integrator-video', partition=0, offset=128, timestamp=1631076816955, timestamp_type=0, key=b'17821', value=b'{"request_id": 17821, "request_type": "video_url", "log_id": 15096, "category_id": 1, "object_id": 1, "field_name": "VideoUrl", "field_value": "https://fbang-web-assets.s3.ap-southeast-1.amazonaws.com/common/ELDEN+RING+-+Official+Gameplay+Reveal.mp4"}', checksum=None, serialized_key_size=5, serialized_value_size=251, headers=())
ConsumerRecord(topic='ai-integrator-video', partition=0, offset=129, timestamp=1631076817013, timestamp_type=0, key=b'17830', value=b'{"request_id": 17830, "request_type": "video_url", "log_id": 15099, "category_id": 1, "object_id": 1, "field_name": "VideoUrl", "field_value": "https://fbang-web-assets.s3.ap-southeast-1.amazonaws.com/common/ELDEN+RING+-+Official+Gameplay+Reveal.mp4"}', checksum=None, serialized_key_size=5, serialized_value_size=251, headers=())
ConsumerRecord(topic='ai-integrator-image', partition=0, offset=83, timestamp=1631006970595, timestamp_type=0, key=b'17351', value=b'{"request_id": 17351, "request_type": "image_url", "log_id": 1367, "category_id": 4, "object_id": 68, "field_name": "ImageUrl", "field_value": "https://fbang-live-test.s3.ap-southeast-1.amazonaws.com/Android1625728071982.png"}', checksum=None, serialized_key_size=5, serialized_value_size=226, headers=())
ConsumerRecord(topic='ai-integrator-image', partition=0, offset=84, timestamp=1631006970595, timestamp_type=0, key=b'17354', value=b'{"request_id": 17354, "request_type": "image_url", "log_id": 1368, "category_id": 4, "object_id": 69, "field_name": "ImageUrl", "field_value": "https://fbang-live-test.s3.ap-southeast-1.amazonaws.com/Android1625728119710.png"}', checksum=None, serialized_key_size=5, serialized_value_size=226, headers=())
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment