kafka-go
kafka-go copied to clipboard
segmentio
Kafka library in Go
I want to subscribe multi topics with a standalone consumer. Does it seem like both Reader and Conn don‘t support this situation?
**Describe the solution you'd like** Reader and Writer in this library open the number of connections proportional to the number of partitions of the topic. Also writer allows us to...
**Describe the bug** Following up from https://github.com/segmentio/kafka-go/pull/890, it appears that multiple implementations of `Merge` were not properly handling error cases, we should audit them and address any other issues. **Expected...
Sketch of a transaction api for the writer with mode code as a TODO Based on https://www.confluent.io/blog/transactions-apache-kafka/ I tried to make it similar to the SQL package but I'm not...
**Describe the bug** When trying to read from a compacted topic using the `FirstOffset` configuration without a consumer group, the library panics with the following stacktrace. ``` panic: markRead: negative...
It seems as if the Consumer does not support crc checking by default when fetching messages and I cannot find any configuration that enables it. In addition, the client library...
After instantiating a new Reader object I can set the offset value to a positive integer or the FirstOffset (-2) successfully. When attempting to set the offset to the last...
Hi Guys, **Describe the bug** I have a secure cluster with mTLS, with a compacted topic, actually it is a Debesium CDC topic. with a config like this: ```text cleanup.policy=compact,...
**Describe the bug** After the "Unexpected EOF", I met another problems when I used v0.4.31, the writer always send an error named "read tcp xxx.xxx.xxx.xxx:xxxx->xxx.xxx.xxx.xxx:xxxx: i/o timeout", but when I...
