root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 5 Packages Projects Releases Wiki Activity

remove exception

This commit is contained in:
Shashank Hosahalli Shivamurthy 2025-10-06 18:39:16 -07:00
parent a51d19b800
commit 38f9b9f1a6
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/AtLeastOnceDeliveryMessageLossIntegrationTest.java
View File

@ -183,7 +183,7 @@ public class AtLeastOnceDeliveryMessageLossIntegrationTest {
streamsConfiguration.put(ProducerConfig.BATCH_SIZE_CONFIG, 33554432); streamsConfiguration.put(ProducerConfig.BATCH_SIZE_CONFIG, 33554432);
} }
private void produceInputData(final int recordCount) throws Exception { private void produceInputData(final int recordCount) {
final List<KeyValue<String, String>> inputRecords = new ArrayList<>(); final List<KeyValue<String, String>> inputRecords = new ArrayList<>();
for (int i = 1; i <= recordCount; i++) { for (int i = 1; i <= recordCount; i++) {
inputRecords.add(new KeyValue<>(String.valueOf(i), "item-" + i)); inputRecords.add(new KeyValue<>(String.valueOf(i), "item-" + i));