aloyszhang edited a comment on issue #7476:
URL: https://github.com/apache/pulsar/issues/7476#issuecomment-656712253
@sijie, Thanks for you reply.
This problem has happened several times in our pulsar cluster. At the first
time, I thought it was caused by session expires, but no SessionExpired
related log can be found.
```java
localZkConnectionSvc.start(new ZookeeperSessionExpiredHandler() {
@Override
public void onSessionExpired() {
log.error("Shutting down ZK sessions: {}", -1);
}
@Override
public void setWatcher(ZooKeeperSessionWatcher watcher) {
}
});
this.localZkCache = new
LocalZooKeeperCache(localZkConnectionSvc.getLocalZooKeeper(),
(int)
TimeUnit.MILLISECONDS.toSeconds(zookeeperSessionTimeoutMs),
this.orderedExecutor);
localZkConnectionSvc.start(new ZookeeperSessionExpiredHandler() {
@Override
public void onSessionExpired() {
try {
localZkCache.getZooKeeper().close();
} catch (InterruptedException e) {
log.warn("Failed to shutdown ZooKeeper gracefully {}",
e.getMessage(), e);
}
}
```
If we assume it was caused by zk session expires, does it means that
connection with zk cluster has been broken?
What should we do in this situation, just restart the service or any other
suggenstions?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
