-
InfluxDB
Power Real-Time Data Analytics at Scale. Get real-time insights from all types of time series data with InfluxDB. Ingest, query, and analyze billions of data points in real-time with unbounded cardinality.
This is a great little library. Several years ago I wrote this tiny (very flakey) in memory topic producer cache - https://github.com/jeremylcarter/PartitionCache. The purpose was to create something like Event Hubs and/or Kafka but in memory only - just to split up workloads by a producer key. I have since seen how bad my initial implementation was, and I did rewrite it - but haven't pushed the branch up.
Perhaps there is a use case for you to have keyed producers. Whereby the same items from the same producer ID are always processed by the same worker - even if it were just round robin assignment to a "batch".
I have also dabbled in the Qoollo Turbo library which has a nice QueueProcessor which is easy to extend (see QueueAsyncProcessor) - you should check that out too for inspiration.
Related posts
-
BatchPool – A .NET task batching and management library
-
I made a .NET task batching and management library. After writing this 3 times at previous jobs, I propose an Open-Source library!
-
OpenAI demo some ChatGPT and GPT-4 updates on 13 May
-
OpenAI page changed: new Search picture
-
OpenAI Website Relaunch