Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Disable concurrency in the AbstractConsumerSeekAwareTests

Browse Source
This commit is contained in:
Artem Bilan
2024-07-15 16:48:21 -04:00
parent 6f0737fe0d
commit f199334961
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-kafka/src/test/java/org/springframework/kafka/listener/AbstractConsumerSeekAwareTests.java
View File

@@ -168,12 +168,12 @@ class AbstractConsumerSeekAwareTests {
static CountDownLatch latch2 = new CountDownLatch(2);
@KafkaListener(groupId = "group1", topics = TOPIC, concurrency = "2")
@KafkaListener(groupId = "group1", topics = TOPIC/*TODO until we figure out non-relevant partitions on assignment, concurrency = "2"*/)
void listenForGroup1(String in) {
latch1.countDown();
}
@KafkaListener(groupId = "group2", topics = TOPIC, concurrency = "2")
@KafkaListener(groupId = "group2", topics = TOPIC/*TODO until we figure out non-relevant partitions on assignment, concurrency = "2"*/)
void listenForGroup2(String in) {
latch2.countDown();
}