The writerCache in DataStore did not use the partitionId in its cache key. Therefore the cache could return the wrong writer and events were written to the wrong partition. Fixed by changing the cache key.
The writerCache in DataStore did not use the partitionId in its cache key. Therefore the cache could return the wrong writer and events were written to the wrong partition. Fixed by changing the cache key.