Skip to content

zookeeper connection cause resource leak #6228

@zplinuxlover

Description

@zplinuxlover

in class ZookeeperBkClientFactoryImpl, the create method

if (zk.getState() == States.CONNECTEDREADONLY && sessionType != SessionType.AllowReadOnly) {
                    future.completeExceptionally(new IllegalStateException("Cannot use a read-only session"));
                }

although this code can not reach, but pulsar should handle 'zookeeper.close' for this code

Metadata

Metadata

Assignees

No one assigned

    Labels

    help wantedtype/bugThe PR fixed a bug or issue reported a bug

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions