We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 343e7a6 commit 63a7bbcCopy full SHA for 63a7bbc
src/Confluent.Kafka/Producer.cs
@@ -552,7 +552,7 @@ private void InitializeSerializers(
552
valueSerializer = (ISerializer<TValue>)serializer;
553
this.serializeValue = (k, ctx) => valueSerializer.Serialize(k, ctx)?.AsMemory();
554
}
555
- else if (memorySerializeFuncs.TryGetValue(typeof(TKey), out object serialize))
+ else if (memorySerializeFuncs.TryGetValue(typeof(TValue), out object serialize))
556
{
557
this.serializeValue = (Func<TValue, SerializationContext, ReadOnlyMemory<byte>?>)serialize;
558
0 commit comments