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.
For recreating the client, need the ability to check the configuration separately. in continuation #195.
Hi, We have a problem with misconfiguring topic names, and I'd like to catch and fatal on this error. Reading the docs, my understanding is KeepRetryableFetchErrors() should do this, and...
In my integration tests, I'm pushing some messages to Kafka topic `kafka-test-topic` and then I'm consuming them them. I'm using franz-go version `v1.15.4`. If I am using one of the...
is a revoke or lost message guaranteed? I have noticed that my consumer didn't seem to have received one when it got kicked out of the group. if it should...
Hi there, I have an issue that the same partitions assign to consumer 2 times in a row. ``` 1 2024-01-09T01:00:00.077418+00:00 microservice - - main: Start version=0.0.0 commit=... 1 2024-01-09T01:00:00.098722+00:00...
Came across this while writing unit tests to assert I was configuring a client properly. Wrong assumption made at [pkg/kgo/client.go#L239-L243](https://github.com/twmb/franz-go/blob/master/pkg/kgo/client.go#L239-L243): ```go case namefn(WithLogger): if cfg.logger != nil { return []any{cfg.logger.(*wrappedLogger).inner}...
- [ ] change SetOffsets to accept arbitrary offsets (remove "must have consumed" restriction) - [ ] #622 - [ ] add `kversion.ParseVersion(string) *Versions` - [ ] Bump to go1.19:...
The kfake package is a great tool to test error cases that can not be reproduced with integration tests. The ACL request and response schemes are somewhat hard to grasp...
This is a follow-up to https://github.com/twmb/franz-go/pull/467#discussion_r1231620122. This PR includes the following changes: - Rename `Opt` to `ClientOpt` - Rename `SerdeOpt` to `EncodingOpt` - Introduce a new `SerdeOpt`, which will ultimately...
