opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-01 15:47:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix DefaultLitePullConsumerTest#testConsumerCommitSyncWithMQOffset (#4973)

Browse Source
This commit is contained in:
Aaron Ai
2022-09-02 15:00:09 +08:00
committed by GitHub
parent 9104d0e3da
commit ec0426ca0e
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/test/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumerTest.java
+3 -2
View File
@@ -20,13 +20,13 @@ package org.apache.rocketmq.client.consumer;
import java.io.ByteArrayOutputStream;
import java.lang.reflect.Field;
import java.net.InetSocketAddress;
import java.time.Duration;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import org.apache.commons.lang3.reflect.FieldUtils;
import org.apache.rocketmq.client.ClientConfig;
@@ -67,6 +67,7 @@ import org.mockito.stubbing.Answer;
import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Fail.failBecauseExceptionWasNotThrown;
import static org.awaitility.Awaitility.await;
import static org.junit.Assert.assertEquals;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.ArgumentMatchers.anyBoolean;
@@ -189,7 +190,7 @@ public class DefaultLitePullConsumerTest {
//mock assign and reset offset
litePullConsumer.assign(set);
litePullConsumer.seek(messageQueue, 0);
await().atMost(Duration.ofSeconds(5)).untilAsserted(() -> assertThat(litePullConsumer.committed(messageQueue)).isEqualTo(0));
//commit offset 1
Map<MessageQueue, Long> commitOffset = new HashMap<>();
commitOffset.put(messageQueue, 1L);