Pavlo
@mensfeld WDYT?
But this is what rdkafka actually allows you to set in it's example. The main usecase for me is to set offset to the beginning of the partition explicitly upon...
I'm totally fine writing it myself, just want to agree on API beforehand. From usability standpoint `def subscribe(*topics_or_tpl)` where there may be multiple topics or single tpl is the best...
Hello. You are welcome to do the PR if the Faraday APIs have changed :)
I don't like the solution. If the first argument is JSON object - you will not be able to pass it at all.
`client.foo(:some => { :nested => :hash })` - this is the call of method `foo` with the first parameter `{ :some => { :nested => :hash } }`
No, I mean that my hash is not named params, but just the first parameter of the method. In your implementation we cannot do this anymore.
managed to get a tcpdump: https://gist.github.com/fxposter/f336c79bad578e8c6c471f45c70f45b5 the difference I see is default mss... btw, I'm using the last alpha release of core os: 1097.0.0
@aaronlevy that can be fixed by having these additional iptables rules on every node (though, I'm not sure why that is not a default): ``` iptables -t nat -I POSTROUTING...
for now the "fix" for us is to monkey-patch the HTTP::Timeout::PerOperation#readpartial method, replacing the line mentioned above with this: ``` begin result = @socket.read_nonblock(size, buffer, :exception => false) rescue =>...