demo.cast

{"version": 2, "width": 80, "height": 24, "timestamp": 1787718855, "idle_time_limit": 2.0, "env": {"SHELL": "/bin/bash", "TERM": "xterm-256color"}}
[0.03, "o", "=== build client ===\r\n"]
[1.16, "o", "\r\n=== start server (docker compose, building if needed) ===\r\n"]
[14.68, "o", "\r\n=== create topic 'demo-events-1787718855' with 3 partitions ===\r\n"]
[16.0, "o", "created topic demo-events-1787718855 with 3 partition(s)\r\n"]
[16.5, "o", "demo-events-1787718855: 3 partition(s)\r\n"]
[17.5, "o", "\r\n=== produce keyed messages (note partition assignments) ===\r\n"]
[18.5, "o", "produced to demo-events-1787718855 partition=1 offset=0\r\n"]
[19.2, "o", "produced to demo-events-1787718855 partition=1 offset=1\r\n"]
[19.9, "o", "produced to demo-events-1787718855 partition=1 offset=2\r\n"]
[20.6, "o", "produced to demo-events-1787718855 partition=2 offset=0\r\n"]
[22.0, "o", "\r\n=== consume everything, merged across partitions ===\r\n"]
[22.5, "o", "(ordering is per-partition/per-key; merge by timestamp is best-effort)\r\n"]
[24.0, "o", "partition=1 offset=0 ts=1787718870236248199 key=\"user-1\" value=\"order:42\"\r\npartition=1 offset=1 ts=1787718870241098629 key=\"user-2\" value=\"order:43\"\r\npartition=1 offset=2 ts=1787718870246015313 key=\"user-1\" value=\"order:44\"\r\npartition=2 offset=0 ts=1787718870250753314 key=\"user-3\" value=\"order:45\"\r\n-- 4 message(s) across 3 partition(s), merged by timestamp\r\n"]
[26.0, "o", "\r\n=== verify bytes at rest with mqvalidate ===\r\n"]
[27.5, "o", "17 topics, 51 segments, 58 messages, 2430 bytes, 0 problems\r\n"]
[28.0, "o", "on-disk data: OK\r\n"]
[29.0, "o", "\r\n=== cleanup ===\r\n"]
[29.184057, "o", "\u001b[?25l\u001b[0G[+] stop 0/1\r\n"]
[29.184254, "o", " \u001b[33m\u280b\u001b[0m Container message-queue-server-1 Stopping                                \u001b[34m0.1s\u001b[0m\r\n\u001b[?25h"]
[29.284018, "o", "\u001b[?25l\u001b[2A\u001b[0G[+] stop 0/1\r\n \u001b[33m\u2819\u001b[0m Container message-queue-server-1 Stopping                                \u001b[34m0.2s\u001b[0m\r\n\u001b[?25h"]
[29.355406, "o", "\u001b[?25l\u001b[2A\u001b[0G[+] stop 1/1\r\n \u001b[32m\u2714\u001b[0m Container message-queue-server-1 \u001b[32mStopped\u001b[0m                                 \u001b[34m0.2s\u001b[0m\r\n\u001b[?25h"]
[29.362551, "o", "demo complete.\r\n"]