Examples of using go-kit-kafka with various Apache Kafka client libraries
-
producer - the service that provide an endpoint to produce an event
-
consumer - the service that able to consume events from kafka topic, store them the in inmemory storage and provide an endpoint to list all consumed events
Bootstrap full project using docker-compose:
docker-compose -f <example>/docker-compose.yml up
To produce an event send the following request:
curl -X POST http://localhost:8080/events
To view all events send the following request:
curl -X GET http://localhost:8081/events