fix(proxy): fix DLQServiceTest#send_group_not_allowed_dlq

1. fix DLQServiceTest#send_group_not_allowed_dlq Signed-off-by: TheR1sing3un <[email protected]>
AutoMQ · Oct 20, 2023 · 83edc63 · 83edc63
1 parent 6256e94
commit 83edc63
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/proxy/src/test/java/com/automq/rocketmq/proxy/service/DLQServiceTest.java b/proxy/src/test/java/com/automq/rocketmq/proxy/service/DLQServiceTest.java
@@ -148,6 +148,12 @@ public void send_group_not_allowed_dlq() {
             .setName(DLQ_TOPIC_NAME)
             .addAcceptMessageTypes(MessageType.TRANSACTION)
             .build();
+        consumerGroup = ConsumerGroup.newBuilder()
+            .setGroupId(CONSUMER_GROUP_ID)
+            .setName(CONSUMER_GROUP_NAME)
+            .setGroupType(GroupType.GROUP_TYPE_STANDARD)
+            .setDeadLetterTopicId(DLQ_TOPIC_ID)
+            .build();
         Mockito.doReturn(CompletableFuture.completedFuture(dlqTopic))
             .when(metadataService).topicOf(DLQ_TOPIC_ID);
         Mockito.doReturn(CompletableFuture.completedFuture(consumerGroup))