Adrien Guillo

We've designed a solution for distributed ingestion and indexing. Design docs are currently on Notion, but we will eventually commit them to our internal docs.

See #3743 insead.

@morrisonlevi provided some context in his original PR: #978. My use case is similar. I recently wrote a few custom `Message` implementations for types with some fields for which I...

@caspermeijn, is there any chance you can look into this PR?

I'm also running into this issue. I've looked into replacing `BytesAdapter` with `BufMut`, but `Bytes::replace_with` requires the ability to reset the buffer, which I don't think you can do with...

The Kafka source now does a better job at logging the values (max poll interval and session timeout) that can lead to the consumer crashing when experiencing backpressure. Downstream, the...

The retry work in `tower` is not going to land anytime soon, so we need a workaround solution in the meantime. Let's implement a `RetryingMetastore` that implements the usual exponential...

Closed via #2335.

For the airmail project, `diff` and `percentiles` are required: - `diff` returns the largest difference between values for each interval - `percentiles` returns the nth percentile for each interval (75th,...

@trinity-1686a, I'm interested in this patch. Could you fix the mrecordlog API to return a single struct and update this PR when you can?