copper-face-jacks serves as an implementation of a Kafka consumer application.

1. Subscribes to test_topic topic and consumes messages
2. Parses the message
3. Sends message to redis

To run the full capability, you'll need both the producer hairy-lemon and the consumer copper-face-jacks. copper-face-jacks is only 50% of the capability.

Below is the bird's eye view of the e2e initiative. The red enclosure represents copper-face-jacks.

• go v.1.13.1+
• kafka container from confluentinc's docker-compose.yaml
• dep for managing dependencies
• redis container

1. Initialize redis instance by running below commands in cli:

   $ docker pull redis
   $ docker run --name testredis -p 6379:6379 -d redis
   

2. For initializing kafka instance, copy the yaml file to desktop.

   In the yaml file, delete everything apart from zookeeper and broker configs. Save the file. Next, execute below commands in cli:

   $ docker-compose up
   $ docker ps
   

3. Clone the producer.

   Run hairy-lemon. Open browser and hit the api at http://localhost:8081/score/1

4. Clone the consumer.

   Run copper-face-jacks, which will consume the message from kafka producer, parse it, and send it to redis.

Go to redis docker instance by executing below command in cli:

$ docker exec -it testredis /bin/bash
$ redis-cli
$ keys *

From key* command above, get list of keys that are sent to redis. In our case, you will see key as 1. To get all the values associated with key 1, run:

$ get 1

Maximum respect and many thanks to the developers on these open-source projects for making copper-face-jacks possible:

rcrowley/go-metrics
jcmturner/gofork
klauspost/compress
go-redis/redis
golang/snappy
hashicorp/go-uuid
pierrec/lz4
eapache @ Shopify
davecgh/go-spew