Skip to content

Commit

Permalink
fix(serialization): KafkaBatchContainerSerializer throwing error (#60)
Browse files Browse the repository at this point in the history
  • Loading branch information
stephenlautier authored Feb 29, 2024
1 parent 97d98bc commit d9d3f34
Showing 1 changed file with 1 addition and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -17,9 +17,7 @@ public KafkaBatchContainerSerializer(OrleansJsonSerializer serializer)
public byte[] Serialize(KafkaBatchContainer data, Confluent.Kafka.SerializationContext context)
{
var serializedString = _serializer.Serialize(data, typeof(KafkaBatchContainer));
var bytes = new byte[serializedString.Length];
Encoding.UTF8.GetBytes(serializedString, bytes);
return bytes;
return Encoding.UTF8.GetBytes(serializedString);
}
}
}

0 comments on commit d9d3f34

Please sign in to comment.