Kafka 的密碼認(rèn)證可以通過 Kafka Admin API 實(shí)現(xiàn)。以下是一個(gè)簡(jiǎn)單的示例，展示了如何使用 Python 和 requests 庫(kù)來獲取 Kafka 集群的管理員權(quán)限：

import requests

def get_admin_api_token(kafka_server, admin_user, admin_password):
    url = f"http://{kafka_server}/admin/v2/users"
    headers = {
        "Content-Type": "application/json",
        "Authorization": f"Basic {base64.b64encode(f"{admin_user}:{admin_password}".encode()).decode()}"
    }
    response = requests.post(url, headers=headers)
    if response.status_code == 200:
        return response.json()["token"]
    else:
        raise Exception(f"Failed to get admin token: {response.status_code}")

# 用你的 Kafka 服務(wù)器地址、用戶名和密碼替換以下占位符
kafka_server = "your_kafka_server"
admin_user = "your_admin_user"
admin_password = "your_admin_password"

token = get_admin_api_token(kafka_server, admin_user, admin_password)
print(f"獲取到的管理員 token: {token}")

請(qǐng)確保將 your_kafka_server、your_admin_user 和 your_admin_password 替換為實(shí)際的 Kafka 服務(wù)器地址、用戶名和密碼。