Writing an API for Apache Kafka with Iris

Read the code.

Docker

1. Open docker-compose.yml and replace KAFKA_ADVERTISED_HOST_NAME with your own local address
2. Install Docker
3. Execute the command below to start kafka stack and the go application:

$ 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:

$ 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:

go run main.go

Screens