Skip to content

Commit 2540a71

Browse files
committed
Increase FETCH_MIN_BYTES_CONFIG to 50 in MessageDrivenAdapterTests
**Auto-cherry-pick to `7.0.x`**
1 parent 9e414d6 commit 2540a71

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -398,7 +398,7 @@ protected boolean doSend(Message<?> message, long timeout) {
398398
void testInboundBatch(EmbeddedKafkaBroker embeddedKafka) throws Exception {
399399
Map<String, Object> props = KafkaTestUtils.consumerProps(embeddedKafka, "test2", true);
400400
props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
401-
props.put(ConsumerConfig.FETCH_MIN_BYTES_CONFIG, 46);
401+
props.put(ConsumerConfig.FETCH_MIN_BYTES_CONFIG, 50);
402402
props.put(ConsumerConfig.FETCH_MAX_WAIT_MS_CONFIG, 2000);
403403

404404
DefaultKafkaConsumerFactory<Integer, String> cf = new DefaultKafkaConsumerFactory<>(props);

0 commit comments

Comments
 (0)