kafka-go
kafka-go copied to clipboard
segmentio
Kafka library in Go
**Describe the bug** > A clear and concise description of what the bug is. After serveral hours, produce failed because "cannot allocate memory kafka.(*Client).Produce:" **Kafka Version** > * What version(s)...
Fixes issue #1307 with closing Writer while WriteMessages() is ongoing https://github.com/segmentio/kafka-go/issues/1307 Cause of the issue: * Close takes the lock and goes through writers created in batchMessages closing them in...
Several Docker images used by Segment do not work reliably on Mac M1 laptops, which use the arm64 chipset. Commonly, these are images that were built several years ago, before...
**Describe the bug** When commits are not immediate and/or some events can have a relatively high processing time and topics substain a low traffic, it can lead to lag being...
**Describe the bug** Closing the kafka.Writer while attempting to write a message can cause the process to hang indefinitely. This issue is resolved by closing the writer again. **Kafka Version**...
We need to see which topics do not exist in Kafka clusters if we get an error from WriteMessages. We can't enable the "Auto Topic Creation" config because of our...
Closes https://github.com/segmentio/kafka-go/issues/615 Adds a listener to send re-assignments to a listener. After this, it is possible to possible to provide a listener (optional) to have consumers be notified of changes...
error log like: > the kafka reader got an unknown error reading partition 9 of cysj2-UpdateUsername at offset 472942: unexpected EOF
Currently, errors (at least in async mode) will only go to logs (if configured). With this change, the Close function will return an error that will fail the caller side...
Hi guys. We are using driver segmentio/kafka-go, and encountered several problems: * User should set BatchBytes manually (when driver can just take 'max.message.bytes' from broker) * WriteMessages can be used...
