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.
If topic has no commit offset for a consumer group, then we should not calculate lag for it. For example, topic A current high water offset is 100, but has...
I propose to enrich the `read from broker errored, killing connection` log message adding the Kafka message type as an extra log field. Are you open to such change? If...
Calling `Client.EndTransaction(ctx, kgo.TryAbort)` doesn't abort transaction on the broker and records from it can be consumed with `read_committed` isolation level after next committed transaction: ``` consumed record: topic=test, partition=0, offset=115,...
