Exceptions on deserializing a message

[EugeneKrapivin]

Hey, I've been noticing lately some errors like:

Unable to cast object of type 'System.String' to type 'System.Collections.Generic.Dictionary`2[System.String,System.Object]'.
   at Orleans.Streams.Kafka.Core.OrleansCodeGenOrleans_Streams_Kafka_Core_KafkaBatchContainerSerializer.Deserializer(Type expected, IDeserializationContext context)
   at Orleans.Serialization.SerializationManager.DeserializeInner[TContext,TReader](SerializationManager sm, Type expected, TContext context, TReader reader)
   at Orleans.Serialization.SerializationManager.DeserializeInner(Type expected, IDeserializationContext context)
   at Orleans.Serialization.SerializationManager.DeserializeInner[T](IDeserializationContext context)
   at Orleans.Streams.Kafka.Consumer.ConsumeResultExtensions.ToBatchContainer(ConsumeResult`2 result, SerializationContext serializationContext, QueueProperties queueProperties)
   at Orleans.Streams.Kafka.Core.KafkaAdapterReceiver.<PollForMessages>d__15.MoveNext()
   at Orleans.Streams.PersistentStreamPullingAgent.<ReadFromQueue>d__37.MoveNext()
   at Orleans.Internal.AsyncExecutorWithRetries.<ExecuteWithRetriesHelper>d__4`1.MoveNext()

have you encountered things like that previously? It looks like its failing to deser the BatchContainer specifically the included orleans context.

Thoughts?