Go Kafka Example

Examples

basic

Basic Async Producer

• async producer

Basic Async Consumer Group (3)

• async producer with 3 consumers (same group)

Basic Batch Timeout Optimized

• reduce batch timeout

replicated

• adjust replication factor = 3

How to use

• make up: run the services
• up-rebuild: run services with dockerfile rebuilt (if producer or consumer need to rebuild)
• make down: stop services

Settings

• change REMOVE_RAW to false if you want to see the raw logs of conumser

Packages

• producer: message producer
• consumer: message consumer (also write logs)
• log-paresr: log paresr / analyzer for performance benchmark

Ref

• Kafka: The Definitive Guide v2
• conduktor/kafka-stack-docker-compose
• Implementing a Kafka Producer and Consumer In Golang (With Full Examples) For Production