hello-world

README

Run a hello world on Kafka with go

The purpose of this tutorial is to execute a simple command on the apache kafka cluster.

Requirements

You need first to have a apache kafka cluster deployed. More information here

Certificates

You need to create a directory that will be mounted on the docker container. It must contains the following

• ca.certificate.pem: the cluster certificate

  • GET /cloud/project/{serviceName}/database/kafka/{clusterId}/certificates or
  • Available on the landing page of your cluster in the manager

• access.certificate.pem: the user certificate

  • GET /cloud/project/{serviceName}/database/kafka/{clusterId}/user/{userId}/access or
  • Click Show the certificate in the manager in the User section

• access.key: the user key

  • GET /cloud/project/{serviceName}/database/kafka/{clusterId}/user/{userId}/access
  • Click Show the certificate in the manager in the User section

Build and run

Once you have created your user, and set up your IP restrictions you can run the following:

read URI
## PATH_TO_CERTIFICATES must be a directory containing all the 3 certificates listed previously
read PATH_TO_CERTIFICATES
docker build -t kafka-go-hello-world .
docker run -v $PATH_TO_CERTIFICATES:/certificates kafka-go-hello-world $URI

Dependencies

This example is using the following external dependencies:

• github.com/confluentinc/confluent-kafka-go, License Apache-2.0