Nick Telford
Nick Telford
Kafka's idempotent producer ensures that only one copy of a record is written to the Kafka broker, even in the face of network failures. Sarama supports this feature. I'm not...
In the `kafka` input, the "isolation level" of the consumer should be configurable: https://pkg.go.dev/github.com/Shopify/sarama#IsolationLevel This will enable Kafka inputs to correctly only process records that were committed, and hold off...
When in streaming mode, a if an `http_client` input is disconnected prematurely, it's possible that a prematurely truncated message will be processed. Since in HTTP streams messages are either explicitly...
### Expected behavior Calling `ColumnFamilyHandle#getDescriptor()` should produce either a `ColumnFamilyDescriptor` that can be `close()`d to free the native memory backing it, or no native allocation should occur. ### Actual behavior...
This configuration controls the maximum amount of local state store data to buffer in transaction buffers. When the total uncommitted data, across all stores and all threads, exceeds this value,...
Java 9 introduced [some significant optimizations to String concatenation](https://openjdk.org/jeps/280) that should improve the performance of jmx_exporter considerably, since it does a lot of String concatenation. However, to gain this benefit,...
When we generate metric names, we use the default `StringBuilder` constructor, which allocates a _16 character_ buffer. Most metrics will exceed this, especially when we start adding attributes to it....
**Version info**: qutebrowser v3.1.0 Git commit: Backend: QtWebEngine 6.7, based on Chromium 118.0.5993.220 (from api) Qt: 6.7.0 **Does the bug happen if you start with `--temp-basedir`?**: Yes **Description** When signing...
Instead of waiting until Tasks are assigned to us, we pre-emptively create a `StandbyTask` for each non-empty Task directory found on-disk. We do this before starting any `StreamThread`s, and on...