Commit 5b4acf3
Kafka MessageDrivenAdapterTests: batch race condition
The `ConsumerConfig.FETCH_MIN_BYTES_CONFIG` is `1` byte by default.
Therefore, the batch consumer expectations might be fulfilled too early
just for one record.
Adjust such a config to `12` bytes to be sure that both published records
are received in a single batch: exactly what we expect in the test logic.
(cherry picked from commit c5d08d0)1 parent 37f5cf1 commit 5b4acf3
File tree
1 file changed
+2
-0
lines changed- spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound
1 file changed
+2
-0
lines changedLines changed: 2 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
396 | 396 | | |
397 | 397 | | |
398 | 398 | | |
| 399 | + | |
| 400 | + | |
399 | 401 | | |
400 | 402 | | |
401 | 403 | | |
| |||
0 commit comments