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.
Looks like `SaramaHasher` is not exactly compatible with sarama. I switched from `segmentio/kafka-go` to `franz-go` and noticed that now my keys map to different partition (this is a no-go for...
I'm wondering if there's a reason that there's no tagged release for the schema registry code in `pkg/sr`? Having proper tags would make it easier to update the dependency with...
We're testing the behavior of PollRecords during a temporary Kafka outage and we're trying to avoid getting duplicate records. In our integration test, we read 10k records from Redpanda, call...
Getting lag as nil, in case Lag method was called as `client.Lag(ctx)`, other methods of this library defaults to listing offsets and describing to all the groups/topics incase no group/topic...
# Why have this proposal Some cloud service providers (such as [alibabacloud](https://www.alibabacloud.com/)) haven't implemented OffsetsForLeaderEpoch. # What happened Franz-go uses `OffsetsForLeaderEpoch` to fetch leader epoch/End Offset and compare consumer offset...
Hey again, We recently had a bug in some code that was doing manual assignment of partitions to messages where it was configured with an incorrect number of partitions and...
Hello 👋! We've been using `franz-go` for a while and have our consumers currently configured with the `RangeBalancer`. We want to switch to the `CooperativeStickyBalancer` and were trying to follow...
Hi! I've encountered an issue when OnPartitionsAssigned called twice with the same set of partitions. Here are franz logs with my comments (read from bottom to top): ``` 2024-04-11 11:28:29.115...
First of all, thank you very much for your project. It's very nice to have a good Kafka consumer that respects interfaces (compared to std confluent library) and also gives...
To be able to see how long it took to to produce a batch to pass to monitoring systems to work out if producing timeout is to low or Kafka...
