# https://kafka.apache.org/quickstart


* 52.41.18.116 -> 10.0.1.100
* 54.68.20.222 -> 10.0.1.200

```
echo 'export KAFKA_HEAP_OPTS="-Xmx1000M"' >> ~/.bashrc
wget --content-disposition https://downloads.apache.org/kafka/2.5.0/kafka_2.12-2.5.0.tgz
tar -xzf kafka_2.12-2.5.0.tgz
sudo apt update
sudo apt-get install openjdk-11-jdk-headless
cd kafka_2.12-2.5.0/
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
bin/kafka-server-start.sh -daemon config/server.properties
```
# clean up

```
bin/kafka-server-stop.sh
bin/zookeeper-server-stop.sh
```

# configs

```
advertised.listeners=PLAINTEXT://ec2-52-41-18-116.us-west-2.compute.amazonaws.com:9092
```

```
kafkacat -L -b 52.41.18.116:9092
kafkacat -L -b 54.68.20.222:9092 

```

```
listeners=LARRY://:9092,MOE://:9093
advertised.listeners=LARRY://10.0.1.100:9092,MOE://internal-replication:9093
inter.broker.listener.name=LARRY
listener.security.protocol.map=LARRY:PLAINTEXT,MOE:PLAINTEXT
```