[incubator-tubemq] 26/49: [TUBEMQ-486]Add the delete API of consumer group offset

[yuanbo]

This is an automated email from the ASF dual-hosted git repository.

yuanbo pushed a commit to branch TUBEMQ-421
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git

commit 7dd7268568e51b87af15c0021506ccfb60ee6da6
Author: gosonzhang <gosonzh...@tencent.com>
AuthorDate: Wed Jan 6 11:33:28 2021 +0800

    [TUBEMQ-486]Add the delete API of consumer group offset
---
 .../java/org/apache/tubemq/server/broker/web/BrokerAdminServlet.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/tubemq-server/src/main/java/org/apache/tubemq/server/broker/web/BrokerAdminServlet.java
 
b/tubemq-server/src/main/java/org/apache/tubemq/server/broker/web/BrokerAdminServlet.java
index 1f2fb5d..30d7247 100644
--- 
a/tubemq-server/src/main/java/org/apache/tubemq/server/broker/web/BrokerAdminServlet.java
+++ 
b/tubemq-server/src/main/java/org/apache/tubemq/server/broker/web/BrokerAdminServlet.java
@@ -1104,7 +1104,7 @@ public class BrokerAdminServlet extends 
AbstractWebHandler {
                     for (Integer partitionId : entry.getValue()) {
                         GroupOffsetInfo offsetInfo = new 
GroupOffsetInfo(partitionId);
                         offsetInfo.setPartPubStoreInfo(
-                                storeInfoMap == null ? null 
:storeInfoMap.get(partitionId));
+                                storeInfoMap == null ? null : 
storeInfoMap.get(partitionId));
                         offsetInfo.setConsumeOffsetInfo(
                                 partBookedMap == null ? null : 
partBookedMap.get(partitionId));
                         String queryKey = buildQueryID(group, topic, 
partitionId);