|
104 | 104 | import org.apache.rocketmq.tools.command.CommandUtil; |
105 | 105 |
|
106 | 106 | import java.io.UnsupportedEncodingException; |
107 | | -import java.text.MessageFormat; |
108 | 107 | import java.util.ArrayList; |
109 | 108 | import java.util.Arrays; |
110 | 109 | import java.util.Collections; |
@@ -905,19 +904,19 @@ public void run() { |
905 | 904 | resetOffsetByTimestampOld(addr, topicRouteMap.get(bd.getBrokerName()), group, topic, timestamp, true); |
906 | 905 | successList.add(addr); |
907 | 906 | } catch (Exception e2) { |
908 | | - logger.error(MessageFormat.format("resetOffsetByTimestampOld error. addr={0}, topic={1}, group={2},timestamp={3}", addr, topic, group, timestamp), e); |
| 907 | + logger.error("resetOffsetByTimestampOld error. addr={}, topic={}, group={}, timestamp={}", addr, topic, group, timestamp, e); |
909 | 908 | failureList.add(addr); |
910 | 909 | } |
911 | 910 | } else if (ResponseCode.SYSTEM_ERROR == e.getResponseCode()) { |
912 | 911 | // CODE: 1 DESC: THe consumer group <GID_newggghh> not exist, never online |
913 | 912 | successList.add(addr); |
914 | 913 | } else { |
915 | 914 | failureList.add(addr); |
916 | | - logger.error(MessageFormat.format("resetOffsetNewConcurrent error. addr={0}, topic={1}, group={2},timestamp={3}", addr, topic, group, timestamp), e); |
| 915 | + logger.error("resetOffsetNewConcurrent error. addr={}, topic={}, group={}, timestamp={}", addr, topic, group, timestamp, e); |
917 | 916 | } |
918 | 917 | } catch (Exception e) { |
919 | 918 | failureList.add(addr); |
920 | | - logger.error(MessageFormat.format("resetOffsetNewConcurrent error. addr={0}, topic={1}, group={2},timestamp={3}", addr, topic, group, timestamp), e); |
| 919 | + logger.error("resetOffsetNewConcurrent error. addr={}, topic={}, group={}, timestamp={}", addr, topic, group, timestamp, e); |
921 | 920 | } finally { |
922 | 921 | latch.countDown(); |
923 | 922 | } |
|
0 commit comments