Skip to content

Commit 5e767b0

Browse files
KAFKA-19965: Increasing batch size to fix throttled delivery test
1 parent a8b1fb9 commit 5e767b0

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3492,7 +3492,11 @@ public void testFetchWithThrottledDeliveryBatchesWithIncreasedDeliveryLimit() {
34923492
try (Producer<byte[], byte[]> producer = createProducer();
34933493
ShareConsumer<byte[], byte[]> shareConsumer = createShareConsumer(
34943494
"group1",
3495-
Map.of(ConsumerConfig.SHARE_ACKNOWLEDGEMENT_MODE_CONFIG, EXPLICIT))
3495+
Map.of(
3496+
ConsumerConfig.SHARE_ACKNOWLEDGEMENT_MODE_CONFIG, EXPLICIT,
3497+
ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 512
3498+
)
3499+
)
34963500
) {
34973501
// Produce records in complete power of 2 to fully test the throttling behavior.
34983502
int producedMessageCount = 512;

0 commit comments

Comments
 (0)