# Kafka

## Zookeeper

Installed via homebrew (brew install kafka) which installed Zookeeper as a dependency

```
To have launchd start zookeeper now and restart at login:
  brew services start zookeeper
Or, if you don't want/need a background service you can just run:
  zkServer start
```

Use `brew services start zookeeper` to start zookeeper
Use `brew services stop zookeeper` to stop zookeeper

```
Successfully started `zookeeper` (label: homebrew.mxcl.zookeeper)
```

OR

Use `zkServer start` to start zookeeper and not have auto-restart
Use `zkServer stop` to stop zookeeper

```
gilcrest-mb:~ gilcrest$ zkServer start
ZooKeeper JMX enabled by default
Using config: /usr/local/etc/zookeeper/zoo.cfg
Starting zookeeper ... STARTED
```

## Kafka

```
To have launchd start kafka now and restart at login:
  brew services start kafka
Or, if you don't want/need a background service you can just run:
  zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties & kafka-server-start /usr/local/etc/kafka/server.properties
```

Use `kafka-server-start /usr/local/etc/kafka/server.properties` to start kafka (after starting Zookeeper)

### Add a Topic

```
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic gilcrest
```

### Producer CLI

```
kafka-console-producer --broker-list localhost:9092 --topic gilcrest
```

### Consumer CLI

```
kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
```