logo
Alauda Streaming Service for Kafka
logo
Alauda Streaming Service for Kafka
Navigation
Introduction
Release Notes
Lifecycle Policy
Install
Upgrade
Architecture

Guides

Create Instance
Delete Instance
User Management
Topic Management
Parameter Configuration
Update Scheduling Configuration
Monitoring and Alerts
Log
Restart Instance
Start and Stop Instance

HowTo

Specification Changes
Choosing Connection Address and Configuring Connection Method
Patch Version Upgrade
Client File Configuration
Permissions

API Reference

Kubernetes APIs

Kafka APIs

RdsKafka
RdsTopic
RdsKafkaUser
📝 Edit this page on GitHub
Previous PageUpgrade
Next PageGuides

#Architecture

Alauda Streaming Service for Kafka leverages Kafka's distributed architecture to provide a proven high-availability solution, meeting enterprise requirements for high-throughput, reliable, and elastically scalable message queuing systems.

#TOC

#ZooKeeper Coordination Mode

The ZooKeeper coordination mode is the traditional distributed coordination implementation for Kafka, utilizing a ZooKeeper cluster to manage Kafka cluster metadata, Broker registration, and controller election, among other core functionalities. This mode has the following characteristics:

  • Mature and Stable: Verified in large-scale production environments, it has extremely high reliability.
  • Separation of Concerns: ZooKeeper focuses on cluster coordination, while Kafka brokers concentrate on message processing.
  • Automatic Failover: Controller automatic election achieved via ZooKeeper's watcher mechanism.
  • Metadata Management: Stores key metadata such as topic partition information and consumer offsets.
  • Expansion Dependency: Requires additional maintenance of a ZooKeeper cluster, introducing operational complexity.

kafka zk arch

#Core Components

  1. ZooKeeper Cluster
    A highly available cluster consisting of an odd number of nodes, responsible for the following tasks:

    • Broker registration and health monitoring.
    • Controller election and failover.
    • Topic/partition metadata storage.
    • Consumer group offset management (deprecated versions).
  2. Kafka Broker Cluster
    A messaging processing cluster composed of multiple Broker nodes:

    • Each Broker registers with ZooKeeper upon startup.
    • Partition leader elections are conducted via the controller.
    • Supports horizontal scaling, increasing throughput by adding Brokers.