Ruben Bartelink

FsCodec has a [`UnionConverter`](https://github.com/jet/fscodec#core-converters) which should interoperate with the code Kunjee linked (you tag the type so no registration into the converters list required). (Note FsCodec almost has STJ support...

related: https://github.com/Azure/azure-cosmos-dotnet-v3/issues/1945

should mention that the AllProcessed vs OverrideWritePosition mechanism in Propulsion can be used to deal with the changelog being ahead of the reader

The designs for #145 and #157 should consider the potential overlap with this requirement.

>A prerequisite for this would be that the aggregate object contains the list of original events in addition to the list of new events as it does today. Opening up...

`DeliveryReport` suggests you are using 0.11.x - I believe the v1 DLLs do throw, but v0 never has In wrappers I use/maintain, I throw when using v0: - https://github.com/jet/propulsion/blob/master/src/Propulsion.Kafka0/Bindings.fs#L28 -...

> `new Guid()` Perhaps `Guid.Empty` might be a better way to convey the fact that the value should remain stable? Though I'd favor `"TestConsumerGroupName"` or something more explicit

[This](https://github.com/jet/fskafka) is in F# so not a direct answer to any of these questions but... It's a pretty thin layer using only BCL constructs and a C# style more than...

Given that there's nothign to tie them together in terms of transactional semantics and that this is a very efficient synchronous call, why can't you do that as your own...

+1 - definitely really useful - in Equinox the dominant access strategy is to search backwards until you hit an 'origin' event, which can be any event that gets us...