From 2d6d2ceb29dbbe84fb94b77f4c1405eb751db9b5 Mon Sep 17 00:00:00 2001 From: Dirk Wilden Date: Mon, 27 May 2019 13:55:41 +0200 Subject: [PATCH] Fixed producing value as key in case an avro schema registry is configured --- CHANGELOG.md | 3 +++ operations/producer/AvroMessageSerializer.go | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 7407196..ee1707e 100644 --- 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 index d5817ba..742033e 100644 --- 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"))