Subscriber Example

This GoFr example demonstrates a simple Subscriber that subscribes asynchronously to a given topic and commits based on the handler response.

To run the example follow the below steps:

Run the docker image of kafka and ensure that your provided topics are created before subscribing.

console

docker run --name kafka-1 -p 9092:9092 \
	-e KAFKA_ENABLE_KRAFT=yes \
	-e KAFKA_CFG_PROCESS_ROLES=broker,controller \
	-e KAFKA_CFG_CONTROLLER_LISTENER_NAMES=CONTROLLER \
	-e KAFKA_CFG_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093 \
	-e KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT \
	-e KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:9092 \
	-e KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE=true \
	-e KAFKA_BROKER_ID=1 \
	-e [email protected]:9093 \
	-e ALLOW_PLAINTEXT_LISTENER=yes \
	-e KAFKA_CFG_NODE_ID=1 \
	-v kafka_data:/bitnami \
	bitnami/kafka:3.4

Now run the example using below command :

console

go run main.go