Yes, Kazoo does support ZooKeeper Local Sessions introduced in ZooKeeper 3.5.0, but it’s not enabled by default. Let’s break down what you might be missing and how to get it working properly.

1. Your Cluster Configuration Is Correct (So Far) #

You’ve already set the critical server-side configs required for local sessions—great job here:

• localSessionsEnabled = true: Allows the cluster to accept local session requests.
• localSessionsUpgradingEnabled = true: Lets local sessions upgrade to global sessions if needed (useful for failover scenarios).

No tweaks needed here; this part is solid.

2. Enable Local Sessions in Your Kazoo Client Code #

Your current code creates a global session by default. To trigger a local session, you need to explicitly set the local_session=True parameter when initializing KazooClient, plus a valid session timeout that falls within your cluster’s configured minSessionTimeout and maxSessionTimeout (usually between 2000ms and 20000ms—adjust to match your server settings).

Here’s the modified, working code:

import logging
from kazoo.client import KazooClient

# Initialize client with local session enabled
zk = KazooClient(
    hosts='127.0.0.1:2181',
    session_timeout=30000,  # Match this to your cluster's session timeout range
    local_session=True
)

zk.start()
# Optional: Verify the session type for debugging
print(f"Client ID: {zk.client_id}")
print(f"Is Local Session: {zk.local_session}")  # Should return True
zk.stop()

3. Key Notes to Avoid Pitfalls #

• Session Timeout Alignment: If your session_timeout is outside the cluster’s allowed range, ZooKeeper will automatically adjust it to the nearest valid value. Double-check your server’s zoo.cfg for minSessionTimeout and maxSessionTimeout to ensure consistency.
• Local Session Limitations: Local sessions are tied to a single ZooKeeper node. If that node goes down, your session will expire unless you have localSessionsUpgradingEnabled=true (which lets the session switch to a global one for continuity).
• Kazoo Version Check: Make sure you’re using Kazoo 0.10.0 or later—older versions don’t support the Local Session API from ZooKeeper 3.5+.
• Validation: To confirm it’s working, use ZooKeeper’s command-line tool: run zkCli.sh and execute stat to view active session details, or rely on the zk.local_session attribute in your code.

内容的提问来源于stack exchange，提问作者SikiShen