added graphs

kafka-client/README.md

@@ -16,19 +16,27 @@ docker-compose -p kafka -f docker-compose.yml up
 
 ## Results
 
-All the [benchmarks](/results.out) are performed in the `Intel(R) Core(TM) i7-7660U CPU @ 2.50GHz` machine with `100K` samples and `5` iterations.
+All the [benchmarks](/results.out) are performed in the `Intel(R) Core(TM) i7-7660U CPU @ 2.50GHz` machine by running with `10K` samples and `5` iterations.
 
-![Average](/in-memory-cache/results/Average_Cache.png)
+### Producer
 
-### Average ns / operation
+#### Microsecond / Operation
 
-#### Set Function
+| Sync Producer | Async Producer |
+| -------- | ------- |
+|![SyncProducerTime.png](/kafka-client/results/SyncProducerTime.png)|![AsyncProducerTime.png](/kafka-client/results/AsyncProducerTime.png)|
 
-![Average_ns_per_operation_set.png](/in-memory-cache/results/Average_ns_per_operation_set.png)
+#### Memory Allocation / Operation
 
-#### Get & Remove Function
+| Sync Producer | Async Producer |
+| -------- | ------- |
+|![SyncProducerTime.png](/kafka-client/results/SyncProducerMemoryAllocations.png)|![AsyncProducerTime.png](/kafka-client/results/AsyncProducerMemoryAllocations.png)|
 
-![Average_ns_per_operation_get_remove](/in-memory-cache/results/Average_ns_per_operation_get_remove.png)
+#### Bytes / Operation
+
+| Sync Producer | Async Producer |
+| -------- | ------- |
+|![SyncProducerTime.png](/kafka-client/results/SyncProducerBytes.png)|![AsyncProducerTime.png](/kafka-client/results/AsyncProducerBytes.png)|
 
 ## Libraries
 

kafka-client/confluent/producer.go

@@ -25,7 +25,7 @@ func NewProducer(bootstrapServers string) *Producer {
 	return producer
 }
 
-func (p *Producer) Produce(topic string, key string, value string) {
+func (p *Producer) ProduceSync(topic string, key string, value string) {
 	deliveryChan := make(chan kafka.Event, 1)
 	p.instance.Produce(&kafka.Message{
 		TopicPartition: kafka.TopicPartition{Topic: &topic, Partition: kafka.PartitionAny},
@@ -36,7 +36,7 @@ func (p *Producer) Produce(topic string, key string, value string) {
 	<-deliveryChan
 }
 
-func (p *Producer) ProduceChannel(topic string, key string, value string) {
+func (p *Producer) ProduceAsync(topic string, key string, value string) {
 	p.wg.Add(1)
 	p.instance.Produce(&kafka.Message{
 		TopicPartition: kafka.TopicPartition{Topic: &topic, Partition: kafka.PartitionAny},

kafka-client/franz/producer.go

@@ -26,11 +26,11 @@ func NewProducer(bootstrapServers string) *Producer {
 	return producer
 }
 
-func (p *Producer) Produce(topic string, key string, value string) {
+func (p *Producer) ProduceSync(topic string, key string, value string) {
 	p.instance.ProduceSync(context.Background(), &kgo.Record{Topic: topic, Key: []byte(key), Value: []byte(value)})
 }
 
-func (p *Producer) ProduceChannel(topic string, key string, value string) {
+func (p *Producer) ProduceAsync(topic string, key string, value string) {
 	p.wg.Add(1)
 	p.instance.Produce(context.Background(), &kgo.Record{Topic: topic, Key: []byte(key), Value: []byte(value)}, p.DeliveryReport)
 }

kafka-client/goka/producer.go

@@ -27,11 +27,11 @@ func NewProducer(bootstrapServers string, topic string) *Producer {
 	return producer
 }
 
-func (p *Producer) Produce(key string, value string) {
+func (p *Producer) ProduceSync(key string, value string) {
 	p.instance.EmitSync(key, value)
 }
 
-func (p *Producer) ProduceChannel(key string, value string) {
+func (p *Producer) ProduceAsync(key string, value string) {
 	p.wg.Add(1)
 	promise, err := p.instance.Emit(key, value)
 	if err != nil {

kafka-client/producer_test.go

@@ -26,15 +26,15 @@ func benchmarkConfluentProducer(b *testing.B, prefix string, valueGenerator func
 	b.Run(testName(prefix, "Confluent@Produce"), func(b *testing.B) {
 		b.ResetTimer()
 		for i := 0; i < b.N; i++ {
-			producer.Produce(topicName, generateKey(prefix, i), valueGenerator(i))
+			producer.ProduceSync(topicName, generateKey(prefix, i), valueGenerator(i))
 		}
 		b.StopTimer()
 	})
 
 	b.Run(testName(prefix, "Confluent@ProduceChannel"), func(b *testing.B) {
 		b.ResetTimer()
 		for i := 0; i < b.N; i++ {
-			producer.ProduceChannel(topicName, generateKey(prefix, i), valueGenerator(i))
+			producer.ProduceAsync(topicName, generateKey(prefix, i), valueGenerator(i))
 		}
 		producer.Wait()
 		b.StopTimer()
@@ -47,7 +47,7 @@ func benchmarkFranzProducer(b *testing.B, prefix string, valueGenerator func(int
 	b.Run(testName(prefix, "Franz@Produce"), func(b *testing.B) {
 		b.ResetTimer()
 		for i := 0; i < b.N; i++ {
-			producer.Produce(topicName, generateKey(prefix, i), valueGenerator(i))
+			producer.ProduceSync(topicName, generateKey(prefix, i), valueGenerator(i))
 		}
 
 		b.StopTimer()
@@ -56,7 +56,7 @@ func benchmarkFranzProducer(b *testing.B, prefix string, valueGenerator func(int
 	b.Run(testName(prefix, "Franz@ProduceChannel"), func(b *testing.B) {
 		b.ResetTimer()
 		for i := 0; i < b.N; i++ {
-			producer.ProduceChannel(topicName, generateKey(prefix, i), valueGenerator(i))
+			producer.ProduceAsync(topicName, generateKey(prefix, i), valueGenerator(i))
 		}
 
 		producer.Wait()
@@ -70,7 +70,7 @@ func benchmarkGokaProducer(b *testing.B, prefix string, valueGenerator func(int)
 	b.Run(testName(prefix, "Goka@Produce"), func(b *testing.B) {
 		b.ResetTimer()
 		for i := 0; i < b.N; i++ {
-			producer.Produce(generateKey(prefix, i), valueGenerator(i))
+			producer.ProduceSync(generateKey(prefix, i), valueGenerator(i))
 		}
 
 		b.StopTimer()
@@ -79,7 +79,7 @@ func benchmarkGokaProducer(b *testing.B, prefix string, valueGenerator func(int)
 	b.Run(testName(prefix, "Goka@ProduceChannel"), func(b *testing.B) {
 		b.ResetTimer()
 		for i := 0; i < b.N; i++ {
-			producer.ProduceChannel(generateKey(prefix, i), valueGenerator(i))
+			producer.ProduceAsync(generateKey(prefix, i), valueGenerator(i))
 		}
 
 		producer.Wait()
@@ -93,15 +93,15 @@ func benchmarkSaramaProducer(b *testing.B, prefix string, valueGenerator func(in
 	b.Run(testName(prefix, "Sarama@Produce"), func(b *testing.B) {
 		b.ResetTimer()
 		for i := 0; i < b.N; i++ {
-			producer.Produce(topicName, generateKey(prefix, i), valueGenerator(i))
+			producer.ProduceSync(topicName, generateKey(prefix, i), valueGenerator(i))
 		}
 		b.StopTimer()
 	})
 
 	b.Run(testName(prefix, "Sarama@ProduceChannel"), func(b *testing.B) {
 		b.ResetTimer()
 		for i := 0; i < b.N; i++ {
-			producer.ProduceChannel(topicName, generateKey(prefix, i), valueGenerator(i))
+			producer.ProduceAsync(topicName, generateKey(prefix, i), valueGenerator(i))
 		}
 		producer.Wait()
 		b.StopTimer()
@@ -114,7 +114,7 @@ func benchmarkSegmentioProducer(b *testing.B, prefix string, valueGenerator func
 	b.Run(testName(prefix, "Segmentio@Produce"), func(b *testing.B) {
 		b.ResetTimer()
 		for i := 0; i < b.N; i++ {
-			producer.Produce(generateKey(prefix, i), valueGenerator(i))
+			producer.ProduceSync(generateKey(prefix, i), valueGenerator(i))
 		}
 
 		b.StopTimer()
@@ -123,7 +123,7 @@ func benchmarkSegmentioProducer(b *testing.B, prefix string, valueGenerator func
 	b.Run(testName(prefix, "Segmentio@ProduceChannel"), func(b *testing.B) {
 		b.ResetTimer()
 		for i := 0; i < b.N; i++ {
-			producer.ProduceChannel(generateKey(prefix, i), valueGenerator(i))
+			producer.ProduceAsync(generateKey(prefix, i), valueGenerator(i))
 		}
 
 		producer.Wait()