I’m stuck on Stage #(change to your stage, ex. #JM3).
listening multiple partition
I’ve tried .. (mention what you’ve tried so far).
Here are my logs: remote: [tester::#KU4] Hexdump of received “DescribeTopicPartitions” response:
remote: [tester::#KU4] Idx | Hex | ASCII
remote: [tester::#KU4] -----±------------------------------------------------±----------------
remote: [tester::#KU4] 0000 | 00 00 00 7d 2c 29 04 a4 00 00 00 00 00 02 00 00 | …},)…
remote: [tester::#KU4] 0010 | 04 71 75 7a 00 00 00 00 00 00 40 00 80 00 00 00 | .quz…@…
remote: [tester::#KU4] 0020 | 00 00 00 25 00 03 00 00 00 00 00 00 00 00 00 01 | …%…
remote: [tester::#KU4] 0030 | 00 00 00 00 02 00 00 00 01 02 00 00 00 01 01 01 | …
remote: [tester::#KU4] 0040 | 01 00 00 00 00 00 00 00 00 00 00 01 00 00 00 00 | …
remote: [tester::#KU4] 0050 | 02 00 00 00 01 02 00 00 00 01 01 01 01 00 00 00 | …
remote: [tester::#KU4] 0060 | 00 00 00 00 00 00 00 01 00 00 00 00 02 00 00 00 | …
remote: [tester::#KU4] 0070 | 01 02 00 00 00 01 01 01 01 00 00 00 0d f8 00 ff | …
remote: [tester::#KU4] 0080 | 03 | .
remote: [tester::#KU4]
remote: [tester::#KU4] [Decoder] - .ResponseHeader
remote: [tester::#KU4] [Decoder] - .correlation_id (740885668)
remote: [tester::#KU4] [Decoder] - .TAG_BUFFER
remote: [tester::#KU4] [Decoder] - .ResponseBody
remote: [tester::#KU4] [Decoder] - .throttle_time_ms (0)
remote: [tester::#KU4] [Decoder] - .topic.length (1)
remote: [tester::#KU4] [Decoder] - .Topics[0]
remote: [tester::#KU4] [Decoder] - .error_code (0)
remote: [tester::#KU4] [Decoder] - .name (quz)
remote: [tester::#KU4] [Decoder] - .topic_id (00000000-0000-4000-8000-000000000025)
remote: [tester::#KU4] [Decoder] - .is_internal (false)
remote: [tester::#KU4] [Decoder] - .num_partitions (2)
remote: [tester::#KU4] [Decoder] - .Partitions[0]
remote: [tester::#KU4] [Decoder] - .error_code (0)
remote: [tester::#KU4] [Decoder] - .partition_index (0)
remote: [tester::#KU4] [Decoder] - .leader_id (1)
remote: [tester::#KU4] [Decoder] - .leader_epoch (0)
remote: [tester::#KU4] [Decoder] - .replica_nodes ([1])
remote: [tester::#KU4] [Decoder] - .isr_nodes ([1])
remote: [tester::#KU4] [Decoder] - .eligible_leader_replicas ()
remote: [tester::#KU4] [Decoder] - .last_known_elr ()
remote: [tester::#KU4] [Decoder] - .offline_replicas ()
remote: [tester::#KU4] [Decoder] - .TAG_BUFFER
remote: [tester::#KU4] [Decoder] - .Partitions[1]
remote: [tester::#KU4] [Decoder] - .error_code (0)
remote: [tester::#KU4] [Decoder] - .partition_index (0)
remote: [tester::#KU4] [Decoder] - .leader_id (1)
remote: [tester::#KU4] [Decoder] - .leader_epoch (0)
remote: [tester::#KU4] [Decoder] - .replica_nodes ([1])
remote: [tester::#KU4] [Decoder] - .isr_nodes ([1])
remote: [tester::#KU4] [Decoder] - .eligible_leader_replicas ()
remote: [tester::#KU4] [Decoder] - .last_known_elr ()
remote: [tester::#KU4] [Decoder] - .offline_replicas ()
remote: [tester::#KU4] [Decoder] - .TAG_BUFFER
remote: [tester::#KU4] [Decoder] - .topic_authorized_operations (0)
remote: [tester::#KU4] [Decoder] - .TAG_BUFFER
remote: [tester::#KU4] [Decoder] - .next_cursor
remote: [tester::#KU4] Received:
remote: [tester::#KU4] Hex (bytes 92-107) | ASCII
remote: [tester::#KU4] ------------------------------------------------±-----------------
remote: [tester::#KU4] 00 00 00 00 00 00 00 01 00 00 00 00 02 00 00 00 | …
remote: [tester::#KU4] ^ ^
remote: [tester::#KU4] Error: Expected COMPACT_STRING length to be > 0, got -1
remote: [tester::#KU4] Context:
remote: [tester::#KU4] - DescribeTopicPartitions v0
remote: [tester::#KU4] - Response Body
remote: [tester::#KU4] - next_cursor
remote: [tester::#KU4] - topic_name
remote: [tester::#KU4] - COMPACT_STRING
remote: [tester::#KU4]
remote: [tester::#KU4] Test failed
include relevant logs here (please make sure to keep the backticks around this!)
And here’s a snippet of my code:
include relevant code here (please make sure to keep the backticks around this!)