Victor Denisov
Victor Denisov
@Jarema Idempotence flag is also a requirement for supporting transactions. You can read it here: https://docs.google.com/document/d/11Jqy_GjUGtdXJK94XGsEIK7CP1SnQGdp2eF0wSw9ra8/edit# Look at pages 21-22. Please notify me about your PRs.
I realized that it needs to take into account the config option. Don't merge yet.
Sure. Newer versions of kafka allow us to use transactions for consuming and producing messages. In order to mark the committed and aborted messages kafka brokers use control messages. Here...
@achille-roussel Is there anything else I can do to facilitate the merge? It's a pretty useful independent change. It allows go clients to successfully consume from topics that were populated...
I can finish it if you are interested in merging @achille-roussel
Yes. This PR basically assumes that there are only two types of messages. Commit and Abort. It should probably be adjusted to reject unknown Types of ControlMessages.
I don't think it's related. The problem I describe only becomes critical when you are reading from many topics simultaneously. Unlike confluent clients this client starts as many connections per...
In one case we have 6 topics and 24 partitions for each. All together it becomes pretty big number especially given that fact that in addition to active connections this...
@geekosaur who do you mean by they? xfce?