kafka-go
kafka-go copied to clipboard
segmentio
Kafka library in Go
A lot of unexpected EOF error when reading from partition cause by `newMessageSetReader` but remain is zero. resolves #1286
**Describe the bug** > A clear and concise description of what the bug is. a lot of unexpected EOF error when reading from partition cause here. https://github.com/segmentio/kafka-go/blob/2af3101bdba0698ff97117cd2b0051510d996df7/reader.go#L1421-L1433 I was try...
**Describe the solution you would like** Currenty in writer.go, during writebatch function call, we have loop on maxattempts and a backoff delay which is exponential based on attempt and a...
In general I see that many functions in this library, e.g. `kafka.NewReader` panic on error. It should return an error instead, because it's not up to a library to figure...
My service is hosted on Kubernetes cluster and my use case is, I have one consumer group as **C1**, which is consuming messages from topic **T1** which has **70** partitions....
The majority of logged messages don't have newlines at the end - this PR makes the rest of the logged messages consistent.
As far as I can see from the README, for the moment there is only an option to provide a logger implementation that will log all internal messages of the...
I am using go1.16. When running tests, I encountered an error "unix/syscall.go:83:16: undefined: unsafe.Slice". Upon further investigation, I found that the kafka-go package references testify v1.8.0, which requires at least...
Add `Flush` method to writer. The `Flush` method immediately writes the current batch to each partition no matter the batch size or timeout. This is useful to manage the `Writer`...
