Leo Gorodinski
Leo Gorodinski
Create a `CSharp.fs` with namespace `Kafunk.CSharp` with adapters for idiomatic C#. Some thoughts: - Convert `Async` to `Task`. - Convert the functional ADP style, to a OOP style: - `KafkaConnection`...
Currently, the logic to route requests to brokers is contained in the connection. Fetch, Produce and Offset requests can be addressed to multiple brokers based on the partitions involved. When...
Expose `Metadata` field on `OffsetCommitRequest` and `OffsetFetchResponse`.
Currently, there is a single script in the tests project which invokes various protocol operations on a running Kafka instance. This should be split up to capture individual operations.
Currently, CodecTests.fs tests a few of the message types. We should have tests for all of them, ideally.
According to http://stackoverflow.com/questions/16305496/optimization-of-function-value-access-in-record-using-f repeated calls to functions contained in records can be slow because the compiler doesn't inline. Determine whether this applies in Aggregate.fs or other places.
This would support the approach nowadays referred to as [bottled water](http://www.confluent.io/blog/bottled-water-real-time-integration-of-postgresql-and-kafka/). One way would be to do an additional insert, into a row space ordered by a global timestamp. Then...