iris/_examples/kafka-api/README.md

# Writing an API for Apache Kafka with Iris

Read the [code](main.go).

## Docker

1. Open [docker-compose.yml](docker-compose.yml) and replace `KAFKA_ADVERTISED_HOST_NAME` with your own local address
2. Install [Docker](https://www.docker.com/)
3. Execute the command below to start kafka stack and the go application:

```sh
$ docker-compose up
```

### Troubleshooting

On windows, if you get an error of `An attempt was made to access a socket in a way forbidden by its access permissions`

Solution:

1. Stop Docker
2. Open CMD with Administrator privileges and execute the following commands:

```sh
$ dism.exe /Online /Disable-Feature:Microsoft-Hyper-V
$ netsh int ipv4 add excludedportrange protocol=tcp startport=2181 numberofports=1
$ dism.exe /Online /Enable-Feature:Microsoft-Hyper-V /All
$ docker-compose up --build
```

## Manually

Install & run Kafka and Zookeper locally and then:

```sh
go run main.go
```

## Screens

![](0_docs.png)

![](1_create_topic.png)

![](2_list_topics.png)

![](3_store_to_topic.png)

![](4_retrieve_from_topic_real_time.png)