This is a simple project to test 4 popular Kafka libraries for Go. Our libraries are :

How to

We can get a simple benchmark from these libraries.

func BenchmarkProduceConfluent(b *testing.B) {
    count := b.N

    messages := make([]Message, count)

    for i := 0; i < count; i++ {
        messages[i] = Message{Key: "Confluent", Value: fmt.Sprint(i)}



There is a Makefile for you to run all commands.

Usage: make [target]

  help        Show this help message
  build       Build app's binary
  run         Run the app
  test        Run unit tests
  benchmark   Run benchmark tests

Change configuration in kafka/produce.go :

var (
    host   string   = "localhost:9092"
    topic  string   = "benchmark"

Then, execute the following command to run the benchmark:

$ make benchmark

goos: darwin
goarch: arm64
BenchmarkProduceSegmentio-8          367           3235080 ns/op
BenchmarkProduceConfluent-8         1137           1006395 ns/op
BenchmarkProduceSarama-8             496           2136077 ns/op
BenchmarkProduceGoka-8                10         104631917 ns/op
ok    6.299s
'graphic/operations.png' and 'graphic/time_operations.png' graphics were generated.

And you can see the results in graphic directory.

Total number of operations :


Operation in nanoseconds :


Default process will be handled by the Go testing package. We can also use -benchtime=100x argument to set the minimum amount of time that the benchmark function will run.

Note: You can change the range for values in y axis. Set y_range_max in Makefile as needed.

Support 💛

Donate with Bitcoin Donate with Ethereum


Contributing 🤝

Don’t be shy and reach out to us if you want to contribute 😉

  1. Fork it !
  2. Create your feature branch : git checkout -b my-new-feature
  3. Commit your changes : git commit -am 'Add some feature'
  4. Push to the branch : git push origin my-new-feature
  5. Submit a pull request


Each project may have many problems. Contributing to the better development of this project by reporting them. 👍


View Github