提交 1a7b9502 编写于 作者: M Matteo Merli 提交者: GitHub

Include timezone in datetime printed in stats (#233)

上级 e2df954d
......@@ -105,7 +105,7 @@ import io.swagger.annotations.ApiResponses;
public class PersistentTopics extends AdminResource {
private static final Logger log = LoggerFactory.getLogger(PersistentTopics.class);
private static final DateTimeFormatter DATE_FORMAT = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS").withZone(ZoneId.systemDefault());
private static final DateTimeFormatter DATE_FORMAT = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSSZ").withZone(ZoneId.systemDefault());
private static final String PARTITIONED_TOPIC_PATH_ZNODE = "partitioned-topics";
private static final int PARTITIONED_TOPIC_WAIT_SYNC_TIME_MS = 1000;
......
......@@ -124,7 +124,7 @@ public class PersistentTopic implements Topic, AddEntryCallback {
private static final long POLICY_UPDATE_FAILURE_RETRY_TIME_SECONDS = 60;
public static final DateTimeFormatter DATE_FORMAT = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS").withZone(ZoneId.systemDefault());
public static final DateTimeFormatter DATE_FORMAT = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSSZ").withZone(ZoneId.systemDefault());
// Timestamp of when this topic was last seen active
private volatile long lastActive;
......
......@@ -1103,7 +1103,7 @@ public class ProducerImpl extends ProducerBase implements TimerTask {
return pendingMessages.size();
}
private static DateTimeFormatter DATE_FORMAT = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS")
private static DateTimeFormatter DATE_FORMAT = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSSZ")
.withZone(ZoneId.systemDefault());
private PulsarApi.CompressionType convertCompressionType(CompressionType compressionType) {
......
......@@ -195,7 +195,7 @@ public class ConsumerHandler extends AbstractWebSocketHandler {
return parts.get(8);
}
private static final DateTimeFormatter DATE_FORMAT = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS").withZone(ZoneId.systemDefault());
private static final DateTimeFormatter DATE_FORMAT = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSSZ").withZone(ZoneId.systemDefault());
private static final Logger log = LoggerFactory.getLogger(ConsumerHandler.class);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册