franz-go
franz-go copied to clipboard
twmb
franz-go contains a feature complete, pure Go library for interacting with Kafka from 0.8.0 through 3.6+. Producing, consuming, transacting, administrating, etc.
As a result of the large volume of records generated, we’ve observed in one of our consumers a high number of allocations originated in the `kgo.recordToRecord` function (`~65%` of total...
This PR resolves https://github.com/twmb/franz-go/issues/823 by allowing to reuse consumed records via `kgo.(*Record).Reuse` method.
I'm trying to implement support for a metric counting errors coming from kafka. kgo's metric hooks would let me count broker connect errors and network bytes read & write errors....
Hi, I'm trying to use the kprom plugin with two producers running in the same program to expose separate metrics for each producer. I expected the `WithClientLabel` configuration option to...
