README ¶ 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. 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 KAFKA_CFG_CONTROLLER_QUORUM_VOTERS=1@127.0.0.1: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 : go run main.go Expand ▾ Collapse ▴ Documentation ¶ There is no documentation for this package. Source Files ¶ View all Source files main.go Click to show internal directories. Click to hide internal directories.