I’m stuck on Stage Serial requests #NH4, I cant get rid of the empty body sent to the second connection, it seems there is one byte which is constantly being sent,
I have tried to omit the tag_buffer, however still get the byte 0-1 error, I have tried for several hours I thing this is time to reach out for help
e[33m[tester::#NH4] e[0me[94mRunning tests for Stage #NH4 (Concurrent Clients - Serial requests)e[0m
e[33m[tester::#NH4] e[0me[94m$ ./your_program.sh /tmp/server.propertiese[0m
e[33m[tester::#NH4] e[0me[36mConnecting to broker at: localhost:9092e[0m
e[33m[your_program] e[0mLogs from your program will appear here!
e[33m[tester::#NH4] e[0me[36mConnection to broker at localhost:9092 successfule[0m
e[33m[tester::#NH4] e[0me[94mSending request 1 of 4: "ApiVersions" (version: 4) request (Correlation id: 1521104067)e[0m
e[33m[tester::#NH4] e[0me[36mHexdump of sent "ApiVersions" request: e[0m
e[33m[tester::#NH4] e[0me[36mIdx | Hex | ASCIIe[0m
e[33m[tester::#NH4] e[0me[36m-----+-------------------------------------------------+-----------------e[0m
e[33m[tester::#NH4] e[0me[36m0000 | 00 00 00 23 00 12 00 04 5a aa 34 c3 00 09 6b 61 | ...#....Z.4...kae[0m
e[33m[tester::#NH4] e[0me[36m0010 | 66 6b 61 2d 63 6c 69 00 0a 6b 61 66 6b 61 2d 63 | fka-cli..kafka-ce[0m
e[33m[tester::#NH4] e[0me[36m0020 | 6c 69 04 30 2e 31 00 | li.0.1.e[0m
e[33m[tester::#NH4] e[0me[36me[0m
e[33m[your_program] e[0mWARNING: Runtime environment or build system does not support multi-release JARs. This will impact location-based features.
e[33m[your_program] e[0m2025-02-21 20:37:50.922 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[35] - Received request with correlation ID: 1521104067 for api versions for : 18 , and checking support for version: 4
e[33m[your_program] e[0m2025-02-21 20:37:50.927 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[42] - Correlation id: 1521104067
e[33m[your_program] e[0m2025-02-21 20:37:50.928 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[64] - Versions Api response for correlation ID :1521104067 with message size of 19 bytes
e[33m[tester::#NH4] e[0me[36mHexdump of received "ApiVersions" response: e[0m
e[33m[tester::#NH4] e[0me[36mIdx | Hex | ASCIIe[0m
e[33m[tester::#NH4] e[0me[36m-----+-------------------------------------------------+-----------------e[0m
e[33m[tester::#NH4] e[0me[36m0000 | 00 00 00 13 5a aa 34 c3 00 00 02 00 12 00 03 00 | ....Z.4.........e[0m
e[33m[tester::#NH4] e[0me[36m0010 | 04 00 00 00 00 00 00 | .......e[0m
e[33m[tester::#NH4] e[0me[36me[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m- .ResponseHeadere[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .correlation_id (1521104067)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m- .ResponseBodye[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .error_code (0)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .num_api_keys (1)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .ApiKeys[0]e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .api_key (18)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .min_version (3)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .max_version (4)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .TAG_BUFFERe[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .throttle_time_ms (0)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .TAG_BUFFERe[0m
e[33m[tester::#NH4] e[0me[92m✓ Correlation ID: 1521104067e[0m
e[33m[tester::#NH4] e[0me[92m✓ Error code: 0 (NO_ERROR)e[0m
e[33m[tester::#NH4] e[0me[92m✓ API keys array is non-emptye[0m
e[33m[tester::#NH4] e[0me[92m✓ API version 4 is supported for API_VERSIONSe[0m
e[33m[tester::#NH4] e[0me[92m✓ Test 1 of 4: Passede[0m
e[33m[tester::#NH4] e[0me[94mSending request 2 of 4: "ApiVersions" (version: 4) request (Correlation id: 2117502592)e[0m
e[33m[tester::#NH4] e[0me[36mHexdump of sent "ApiVersions" request: e[0m
e[33m[tester::#NH4] e[0me[36mIdx | Hex | ASCIIe[0m
e[33m[tester::#NH4] e[0me[36m-----+-------------------------------------------------+-----------------e[0m
e[33m[tester::#NH4] e[0me[36m0000 | 00 00 00 23 00 12 00 04 7e 36 86 80 00 09 6b 61 | ...#....~6....kae[0m
e[33m[tester::#NH4] e[0me[36m0010 | 66 6b 61 2d 63 6c 69 00 0a 6b 61 66 6b 61 2d 63 | fka-cli..kafka-ce[0m
e[33m[tester::#NH4] e[0me[36m0020 | 6c 69 04 30 2e 31 00 | li.0.1.e[0m
e[33m[tester::#NH4] e[0me[36me[0m
e[33m[your_program] e[0m2025-02-21 20:37:50.930 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[35] - Received request with correlation ID: 2117502592 for api versions for : 18 , and checking support for version: 4
e[33m[your_program] e[0m2025-02-21 20:37:50.930 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[42] - Correlation id: 2117502592
e[33m[your_program] e[0m2025-02-21 20:37:50.930 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[64] - Versions Api response for correlation ID :2117502592 with message size of 19 bytes
e[33m[tester::#NH4] e[0me[36mHexdump of received "ApiVersions" response: e[0m
e[33m[tester::#NH4] e[0me[36mIdx | Hex | ASCIIe[0m
e[33m[tester::#NH4] e[0me[36m-----+-------------------------------------------------+-----------------e[0m
e[33m[tester::#NH4] e[0me[36m0000 | 00 00 00 13 7e 36 86 80 00 00 02 00 12 00 03 00 | ....~6..........e[0m
e[33m[tester::#NH4] e[0me[36m0010 | 04 00 00 00 00 00 00 | .......e[0m
e[33m[tester::#NH4] e[0me[36me[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m- .ResponseHeadere[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .correlation_id (2117502592)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m- .ResponseBodye[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .error_code (0)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .num_api_keys (1)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .ApiKeys[0]e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .api_key (18)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .min_version (3)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .max_version (4)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .TAG_BUFFERe[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .throttle_time_ms (0)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .TAG_BUFFERe[0m
e[33m[tester::#NH4] e[0me[92m✓ Correlation ID: 2117502592e[0m
e[33m[tester::#NH4] e[0me[92m✓ Error code: 0 (NO_ERROR)e[0m
e[33m[tester::#NH4] e[0me[92m✓ API keys array is non-emptye[0m
e[33m[tester::#NH4] e[0me[92m✓ API version 4 is supported for API_VERSIONSe[0m
e[33m[tester::#NH4] e[0me[92m✓ Test 2 of 4: Passede[0m
e[33m[tester::#NH4] e[0me[94mSending request 3 of 4: "ApiVersions" (version: 4) request (Correlation id: 206818663)e[0m
e[33m[tester::#NH4] e[0me[36mHexdump of sent "ApiVersions" request: e[0m
e[33m[tester::#NH4] e[0me[36mIdx | Hex | ASCIIe[0m
e[33m[tester::#NH4] e[0me[36m-----+-------------------------------------------------+-----------------e[0m
e[33m[tester::#NH4] e[0me[36m0000 | 00 00 00 23 00 12 00 04 0c 53 cd 67 00 09 6b 61 | ...#.....S.g..kae[0m
e[33m[tester::#NH4] e[0me[36m0010 | 66 6b 61 2d 63 6c 69 00 0a 6b 61 66 6b 61 2d 63 | fka-cli..kafka-ce[0m
e[33m[tester::#NH4] e[0me[36m0020 | 6c 69 04 30 2e 31 00 | li.0.1.e[0m
e[33m[tester::#NH4] e[0me[36me[0m
e[33m[your_program] e[0m2025-02-21 20:37:50.974 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[35] - Received request with correlation ID: 206818663 for api versions for : 18 , and checking support for version: 4
e[33m[your_program] e[0m2025-02-21 20:37:50.975 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[42] - Correlation id: 206818663
e[33m[your_program] e[0m2025-02-21 20:37:50.975 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[64] - Versions Api response for correlation ID :206818663 with message size of 19 bytes
e[33m[tester::#NH4] e[0me[36mHexdump of received "ApiVersions" response: e[0m
e[33m[tester::#NH4] e[0me[36mIdx | Hex | ASCIIe[0m
e[33m[tester::#NH4] e[0me[36m-----+-------------------------------------------------+-----------------e[0m
e[33m[tester::#NH4] e[0me[36m0000 | 00 00 00 13 0c 53 cd 67 00 00 02 00 12 00 03 00 | .....S.g........e[0m
e[33m[tester::#NH4] e[0me[36m0010 | 04 00 00 00 00 00 00 | .......e[0m
e[33m[tester::#NH4] e[0me[36me[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m- .ResponseHeadere[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .correlation_id (206818663)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m- .ResponseBodye[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .error_code (0)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .num_api_keys (1)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .ApiKeys[0]e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .api_key (18)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .min_version (3)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .max_version (4)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .TAG_BUFFERe[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .throttle_time_ms (0)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .TAG_BUFFERe[0m
e[33m[tester::#NH4] e[0me[92m✓ Correlation ID: 206818663e[0m
e[33m[tester::#NH4] e[0me[92m✓ Error code: 0 (NO_ERROR)e[0m
e[33m[tester::#NH4] e[0me[92m✓ API keys array is non-emptye[0m
e[33m[tester::#NH4] e[0me[92m✓ API version 4 is supported for API_VERSIONSe[0m
e[33m[tester::#NH4] e[0me[92m✓ Test 3 of 4: Passede[0m
e[33m[tester::#NH4] e[0me[94mSending request 4 of 4: "ApiVersions" (version: 4) request (Correlation id: 778864310)e[0m
e[33m[tester::#NH4] e[0me[36mHexdump of sent "ApiVersions" request: e[0m
e[33m[tester::#NH4] e[0me[36mIdx | Hex | ASCIIe[0m
e[33m[tester::#NH4] e[0me[36m-----+-------------------------------------------------+-----------------e[0m
e[33m[tester::#NH4] e[0me[36m0000 | 00 00 00 23 00 12 00 04 2e 6c 86 b6 00 09 6b 61 | ...#.....l....kae[0m
e[33m[tester::#NH4] e[0me[36m0010 | 66 6b 61 2d 63 6c 69 00 0a 6b 61 66 6b 61 2d 63 | fka-cli..kafka-ce[0m
e[33m[tester::#NH4] e[0me[36m0020 | 6c 69 04 30 2e 31 00 | li.0.1.e[0m
e[33m[tester::#NH4] e[0me[36me[0m
e[33m[your_program] e[0m2025-02-21 20:37:51.018 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[35] - Received request with correlation ID: 778864310 for api versions for : 18 , and checking support for version: 4
e[33m[your_program] e[0m2025-02-21 20:37:51.019 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[42] - Correlation id: 778864310
e[33m[your_program] e[0m2025-02-21 20:37:51.019 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[64] - Versions Api response for correlation ID :778864310 with message size of 19 bytes
e[33m[tester::#NH4] e[0me[36mHexdump of received "ApiVersions" response: e[0m
e[33m[tester::#NH4] e[0me[36mIdx | Hex | ASCIIe[0m
e[33m[tester::#NH4] e[0me[36m-----+-------------------------------------------------+-----------------e[0m
e[33m[tester::#NH4] e[0me[36m0000 | 00 00 00 13 2e 6c 86 b6 00 00 02 00 12 00 03 00 | .....l..........e[0m
e[33m[tester::#NH4] e[0me[36m0010 | 04 00 00 00 00 00 00 | .......e[0m
e[33m[tester::#NH4] e[0me[36me[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m- .ResponseHeadere[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .correlation_id (778864310)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m- .ResponseBodye[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .error_code (0)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .num_api_keys (1)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .ApiKeys[0]e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .api_key (18)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .min_version (3)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .max_version (4)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .TAG_BUFFERe[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .throttle_time_ms (0)e[0m
e[33m[tester::#NH4] [Decoder] e[0me[36m - .TAG_BUFFERe[0m
e[33m[tester::#NH4] e[0me[92m✓ Correlation ID: 778864310e[0m
e[33m[tester::#NH4] e[0me[92m✓ Error code: 0 (NO_ERROR)e[0m
e[33m[tester::#NH4] e[0me[92m✓ API keys array is non-emptye[0m
e[33m[tester::#NH4] e[0me[92m✓ API version 4 is supported for API_VERSIONSe[0m
e[33m[tester::#NH4] e[0me[92m✓ Test 4 of 4: Passede[0m
e[33m[tester::#NH4] e[0me[92mTest passed.e[0m
e[33m[tester::#NH4] e[0me[36mTerminating programe[0m
e[33m[tester::#NH4] e[0me[36mProgram terminated successfullye[0m
e[33m[tester::#PV1] e[0me[94mRunning tests for Stage #PV1 (Handle APIVersions requests)e[0m
e[33m[tester::#PV1] e[0me[94m$ ./your_program.sh /tmp/server.propertiese[0m
e[33m[tester::#PV1] e[0me[36mConnecting to broker at: localhost:9092e[0m
e[33m[your_program] e[0mLogs from your program will appear here!
e[33m[tester::#PV1] e[0me[36mConnection to broker at localhost:9092 successfule[0m
e[33m[tester::#PV1] e[0me[94mSending "ApiVersions" (version: 4) request (Correlation id: 1102921197)e[0m
e[33m[tester::#PV1] e[0me[36mHexdump of sent "ApiVersions" request: e[0m
e[33m[tester::#PV1] e[0me[36mIdx | Hex | ASCIIe[0m
e[33m[tester::#PV1] e[0me[36m-----+-------------------------------------------------+-----------------e[0m
e[33m[tester::#PV1] e[0me[36m0000 | 00 00 00 23 00 12 00 04 41 bd 3d ed 00 09 6b 61 | ...#....A.=...kae[0m
e[33m[tester::#PV1] e[0me[36m0010 | 66 6b 61 2d 63 6c 69 00 0a 6b 61 66 6b 61 2d 63 | fka-cli..kafka-ce[0m
e[33m[tester::#PV1] e[0me[36m0020 | 6c 69 04 30 2e 31 00 | li.0.1.e[0m
e[33m[tester::#PV1] e[0me[36me[0m
e[33m[your_program] e[0mWARNING: Runtime environment or build system does not support multi-release JARs. This will impact location-based features.
e[33m[your_program] e[0m2025-02-21 20:37:52.839 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[35] - Received request with correlation ID: 1102921197 for api versions for : 18 , and checking support for version: 4
e[33m[your_program] e[0m2025-02-21 20:37:52.843 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[42] - Correlation id: 1102921197
e[33m[your_program] e[0m2025-02-21 20:37:52.844 [e[36mmaine[m] e[32mINFO e[m e[34mapis.KafkaVerionse[m->[64] - Versions Api response for correlation ID :1102921197 with message size of 19 bytes
e[33m[tester::#PV1] e[0me[36mHexdump of received "ApiVersions" response: e[0m
e[33m[tester::#PV1] e[0me[36mIdx | Hex | ASCIIe[0m
e[33m[tester::#PV1] e[0me[36m-----+-------------------------------------------------+-----------------e[0m
e[33m[tester::#PV1] e[0me[36m0000 | 00 00 00 13 41 bd 3d ed 00 00 02 00 12 00 03 00 | ....A.=.........e[0m
e[33m[tester::#PV1] e[0me[36m0010 | 04 00 00 00 00 00 00 | .......e[0m
e[33m[tester::#PV1] e[0me[36me[0m
e[33m[tester::#PV1] [Decoder] e[0me[36m- .ResponseHeadere[0m
e[33m[tester::#PV1] [Decoder] e[0me[36m - .correlation_id (1102921197)e[0m
e[33m[tester::#PV1] [Decoder] e[0me[36m- .ResponseBodye[0m
e[33m[tester::#PV1] [Decoder] e[0me[36m - .error_code (0)e[0m
e[33m[tester::#PV1] [Decoder] e[0me[36m - .num_api_keys (1)e[0m
e[33m[tester::#PV1] [Decoder] e[0me[36m - .ApiKeys[0]e[0m
e[33m[tester::#PV1] [Decoder] e[0me[36m - .api_key (18)e[0m
e[33m[tester::#PV1] [Decoder] e[0me[36m - .min_version (3)e[0m
e[33m[tester::#PV1] [Decoder] e[0me[36m - .max_version (4)e[0m
e[33m[tester::#PV1] [Decoder] e[0me[36m - .TAG_BUFFERe[0m
e[33m[tester::#PV1] [Decoder] e[0me[36m - .throttle_time_ms (0)e[0m
e[33m[tester::#PV1] [Decoder] e[0me[36m - .TAG_BUFFERe[0m
e[33m[tester::#PV1] e[0me[92m✓ Correlation ID: 1102921197e[0m
e[33m[tester::#PV1] e[0me[92m✓ Error code: 0 (NO_ERROR)e[0m
e[33m[tester::#PV1] e[0me[92m✓ API keys array is non-emptye[0m
e[33m[tester::#PV1] e[0me[92m✓ API version 4 is supported for API_VERSIONSe[0m
e[33m[tester::#PV1] e[0me[92mTest passed.e[0m
e[33m[tester::#PV1] e[0me[36mTerminating programe[0m
e[33m[tester::#PV1] e[0me[36mProgram terminated successfullye[0m
e[33m[tester::#NC5] e[0me[94mRunning tests for Stage #NC5 (Parse API Version)e[0m
e[33m[tester::#NC5] e[0me[94m$ ./your_program.sh /tmp/server.propertiese[0m
e[33m[tester::#NC5] e[0me[36mConnecting to broker at: localhost:9092e[0m
e[33m[your_program] e[0mLogs from your program will appear here!
e[33m[tester::#NC5] e[0me[36mConnection to broker at localhost:9092 successfule[0m
e[33m[tester::#NC5] e[0me[94mSending "ApiVersions" (version: 20622) request (Correlation id: 421072855)e[0m
e[33m[tester::#NC5] e[0me[36mHexdump of sent "ApiVersions" request: e[0m
e[33m[tester::#NC5] e[0me[36mIdx | Hex | ASCIIe[0m
e[33m[tester::#NC5] e[0me[36m-----+-------------------------------------------------+-----------------e[0m
e[33m[tester::#NC5] e[0me[36m0000 | 00 00 00 23 00 12 50 8e 19 19 0f d7 00 09 6b 61 | ...#..P.......kae[0m
e[33m[tester::#NC5] e[0me[36m0010 | 66 6b 61 2d 63 6c 69 00 0a 6b 61 66 6b 61 2d 63 | fka-cli..kafka-ce[0m
e[33m[tester::#NC5] e[0me[36m0020 | 6c 69 04 30 2e 31 00 | li.0.1.e[0m
e[33m[tester::#NC5] e[0me[36me[0m
e[33m[tester::#NC5] e[0me[36mHexdump of received "ApiVersions" response: e[0m
e[33m[tester::#NC5] e[0me[36mIdx | Hex | ASCIIe[0m
e[33m[tester::#NC5] e[0me[36m-----+-------------------------------------------------+-----------------e[0m
e[33m[tester::#NC5] e[0me[36m| e[0m
e[33m[tester::#NC5] e[0me[36me[0m
e[33m[tester::#NC5] [Decoder] e[0me[36m- .Responsee[0m
e[33m[tester::#NC5] [Decoder] e[0me[91mReceived:e[0m
e[33m[tester::#NC5] [Decoder] e[0me[91mHex (bytes 0--1) | ASCIIe[0m
e[33m[tester::#NC5] [Decoder] e[0me[91m------------------------------------------------+------------------e[0m
e[33m[tester::#NC5] [Decoder] e[0me[91m| e[0m
e[33m[tester::#NC5] [Decoder] e[0me[91m ^ ^e[0m
e[33m[tester::#NC5] [Decoder] e[0me[91mError: Expected int32 length to be 4 bytes, got 0 bytese[0m
e[33m[tester::#NC5] [Decoder] e[0me[91mContext:e[0m
e[33m[tester::#NC5] [Decoder] e[0me[91m- responsee[0m
e[33m[tester::#NC5] [Decoder] e[0me[91m - message lengthe[0m
e[33m[tester::#NC5] [Decoder] e[0me[91m - INT32e[0m
e[33m[tester::#NC5] [Decoder] e[0me[91me[0m
e[33m[tester::#NC5] [Decoder] e[0me[91mTest failede[0m
e[33m[tester::#NC5] [Decoder] e[0me[36mTerminating programe[0m
e[33m[tester::#NC5] [Decoder] e[0me[36mProgram terminated successfullye[0m
View our article on debugging test failures: https://codecrafters.io/debug
here is the link to my repository kafka-replica/src/main/java at master · nindaba/kafka-replica · GitHub
https://github.com/nindaba/kafka-replica/blob/master/src/main/java/apis/KafkaVerions.java
public class KafkaVerions implements KafkaApi {
public static short API_VERSIONS_KEY = (short) 18;
private static final short[] SUPPORTED_VERSIONS = {3, 4};
private static final byte ZERO = 0;
private static final Logger log = LogManager.getLogger(KafkaVerions.class);
@Override
public void handle(short key, int size, InputStream in, OutputStream out) {
try {
var requestMessage = in.readNBytes(size);
var requestBuffer = ByteBuffer.wrap(requestMessage);
var responseBuffer = buffer(19);
var erroCode = ErrorCodes.NONE;
var verion = requestBuffer.getShort();
var correlationId = requestBuffer.getInt();
var api = KafkaApiContext.get(key);
log.info("Received request with correlation ID: {} for api versions for : {} , and checking support for version: {}", correlationId, key, verion);
if (!isSupported(api, key, verion)) {
log.error("Unsupported api: {} version: {} with correlation ID: {}", key, verion, correlationId);
erroCode = ErrorCodes.UNSUPPORTED_VERSION;
}
log.info("Correlation id: {}", correlationId);
responseBuffer.putInt(correlationId)
.putShort(erroCode)
.put((byte) 2)
.putShort(key)
.put(versionRange(key, api))
.put(ZERO)
.putInt(0);
if (verion != 3)
responseBuffer.put(ZERO);
responseBuffer.flip();
var responseSize = responseBuffer.remaining();
var responseMessage = new byte[responseSize];
responseBuffer.get(responseMessage);
log.info("Versions Api response for correlation ID :{} with message size of {} bytes", correlationId, responseMessage.length);
out.write(buffer(4)
.putInt(responseSize)
.array());
out.write(responseMessage);
out.flush();
} catch (IOException e) {
System.err.printf("Could not validate api version %n");
throw new RuntimeException(e);
}
}
}
I would really appreciate if some one to look into this