Skip to content

Commit 43b8c43

Browse files
committed
Consolidate share consumer constraint tests into integration tests
- Replace Thread.sleep() with Awaitility pattern that verifies poll blocking via trace log - Add Mockito spy on LogAccessor to confirm the logging message - Migrate shouldHandlePartialAcknowledgmentCorrectly test from ConstraintTests - Migrate shouldHandleConcurrentAcknowledgmentAttempts test from ConstraintTests - Fix topic collision by assigning unique topics to each test - Remove duplicate ShareKafkaMessageListenerContainerConstraintTests class This improves test reliability by verifying actual blocking behavior rather than assuming Thread.sleep duration is sufficient, and eliminates test duplication. Signed-off-by: Soby Chacko <[email protected]>
1 parent 23fd8c0 commit 43b8c43

File tree

2 files changed

+255
-448
lines changed

2 files changed

+255
-448
lines changed

spring-kafka/src/test/java/org/springframework/kafka/listener/ShareKafkaMessageListenerContainerConstraintTests.java

Lines changed: 0 additions & 347 deletions
This file was deleted.

0 commit comments

Comments
 (0)