Emanuele Sabellico
Emanuele Sabellico
@notnoop Thanks for reporting this! Your issue seems very similar to the one fixed in #4187, that also happened when a topic is removed. Could you try it to see...
Yes, it seems a different problem and could be fixed in the same point. We're checking this, thanks!
Thanks for opening the issue! We could print a message and directly call `abort` if asserts are disabled and condition evaluates to true.
No, it stops fetching a given partition when it reaches `queued.max.messages.kbytes` (64MB) or `queued.min.messages` (100000). You can reduce that value if you need. Also when there aren't new messages Kafka...
@marcin-krystianc Thanks for the report, the implementation of KIP-516 (topic ids) needs to be completed with regards to topic re-creation with same name, there are many fields to reset, among...
Could you add debug logs by configuring `debug=all` this could be a normal message timeout or a network reachability problem as well.
Yeah, aware of it, it was accepted as technical debt when reviewing KIP-714.
Hi @calvin2021y thanks for the report! I fixed it in #5136 because it's incorrect and added some more tests with cmake but I couldn't reproduce because cmake installs libcurl on...
Yeah this can be avoided by saving the callback (and the arg) in a local variable while locked and then using it
Thanks for the fix! Provided a comment.