[KAFKA-15569] Update test and add test cases in IQv2StoreIntegrationTest

• Type: Test
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: streams, unit tests
• Assignee: Hanyu Zheng
• Reporter: Hanyu Zheng
• Created: 09/Oct/23 19:33
• Updated: 17/Oct/23 02:21

Description

• Update test and add test cases in IQv2StoreIntegrationTest.
• Originally, all key-value pairs were confined to a single window, with all data added at WINDOW_START. To improve our testing, we've expanded to multiple windows.
• With a total of 10 records, keys ranging from 0 to 4 determine the designated partition for each message, either 0 or 1. Each consecutive pair of records, such as <0,0> and <0,1> or <1,2> and <1,3>, shares the same key. For instance, both <0,0> and <0,1> are directed to partition 0 due to their shared key '0', while pairs like <1,2> and <1,3>, having the key '1', are sent to partition 1. This pattern is consistent across all records.

Issue Links

• links to: GitHub Pull Request #14523