Fixed producing value as key in case an avro schema registry is confi…

…gured
deviceinsight · May 27, 2019 · 2d6d2ce · 2d6d2ce
1 parent 986ed4c
commit 2d6d2ce
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -6,6 +6,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Fixed
+- Fixed producing value as key in case an avro schema registry is configured.
+
 ## 1.2.0 - 2019-05-24
 
 ### Added

diff --git a/operations/producer/AvroMessageSerializer.go b/operations/producer/AvroMessageSerializer.go
@@ -89,7 +89,7 @@ func (serializer AvroMessageSerializer) Serialize(key, value []byte, flags Produ
 	message := &sarama.ProducerMessage{Topic: serializer.topic, Partition: flags.Partition}
 
 	if key != nil {
-		message.Key = sarama.ByteEncoder(serializer.encode(value, flags.KeySchemaVersion, "key"))
+		message.Key = sarama.ByteEncoder(serializer.encode(key, flags.KeySchemaVersion, "key"))
 	}
 
 	message.Value = sarama.ByteEncoder(serializer.encode(value, flags.ValueSchemaVersion, "value"))