Sylvain Le Gouellec
Sylvain Le Gouellec
Description =========== For now, when an exception is throw during the partition assignment handler, the application crash and you have no errors logs or whatever. It's really hard to diagnose...
Existing state store : - In Memory - RocksDb Maybe a new one : FASTER https://github.com/microsoft/FASTER
Description =========== Add some integration tests with [dotnet testcontainers library](https://github.com/HofmeisterAn/dotnet-testcontainers)
Description =========== Release an open telemetry reporter to export telemetry data
Description =========== Let's suppose this topology : ``` csharp var personStream = builder.Stream("persons", stringSerdes, personSerdes); var locationStream = builder.Stream("locations", stringSerdes, locationSerdes); var jobStream = builder.Stream("jobs", stringSerdes, jobSerdes); personStream .SelectKey((_, v)...
Description =========== - Refactor `ISchemaRegistryConfig` and interaction with shema serdes - Refactor `AddConfig(...), AddAdminConfig(...), AddConsumerConfig(...), AddProducerConfig(....)`
[Description =========== Expose RocksDb metrics properties. [See](https://cwiki.apache.org/confluence/display/KAFKA/KIP-607%3A+Add+Metrics+to+Kafka+Streams+to+Report+Properties+of+RocksDB)