<img src="https://cdn.hashnode.com/res/hashnode/image/upload/v1702504100248/b5695552-7a53-43d4-b4fd-19b3dd16cfc4.png" alt />
Kafka Active Controller
<h3 id="heading-what-is-a-controller">What is a Controller?</h3>
The controller is one of the Kafka brokers, usually behaves like a normal broker, and has a controlling capability of managing partition state and replicas and reassignment of the partition.
<h3 id="heading-how-to-get-the-currently-active-controller">How to get the currently active controller?</h3>
Zookeeper is the storage of the Kafka cluster, who elects the controller node either at the beginning of the cluster setup or when the controller node crashes. Here is the command to get the controller
<ul>
<li>Shell command when installed on the host</li>
</ul>
<pre><code>zookeeper-shell 192.168.1.1:22181 get /controller
</code></pre><ul>
<li>When we are dealing with the docker container we can execute the above command in interactive mode as follows</li>
</ul>
<pre><code># Connect to Zookeeper 
docker run --net=host --rm confluentinc/cp-kafka:4.0.0 zookeeper-shell 192.168.1.1:22181
</code></pre><pre><code># Get the Controller 
docker run --net=host --rm confluentinc/cp-kafka:4.0.0 zookeeper-shell 192.168.1.1:22181 get /controller
</code></pre><blockquote>
Note: <code>*192.168.1.1*</code> is the zookeeper IP
</blockquote>

![](https://cdn.hashnode.com/res/hashnode/image/upload/v1702504100248/b5695552-7a53-43d4-b4fd-19b3dd16cfc4.png)

Kafka Active Controller

### What is a Controller?

The controller is one of the Kafka brokers, usually behaves like a normal broker, and has a controlling capability of managing partition state and replicas and reassignment of the partition.

### How to get the currently active controller?

Zookeeper is the storage of the Kafka cluster, who elects the controller node either at the beginning of the cluster setup or when the controller node crashes. Here is the command to get the controller

*   Shell command when installed on the host

```
zookeeper-shell 192.168.1.1:22181 get /controller
```

*   When we are dealing with the docker container we can execute the above command in interactive mode as follows

```
# Connect to Zookeeper  
docker run --net=host --rm confluentinc/cp-kafka:4.0.0 zookeeper-shell 192.168.1.1:22181
```

```
# Get the Controller  
docker run --net=host --rm confluentinc/cp-kafka:4.0.0 zookeeper-shell 192.168.1.1:22181 get /controller
```

> *Note:* `*192.168.1.1*` *is the zookeeper IP*

Identify the Active Controller In Kafka

What is a Controller?

How to get the currently active controller?