Good question. I would think this PR does not guarantee the absence of duplicate messages. Two possible points for this PR are: 1. Explicitly capturing `TimeoutException` and warning give user a hint that they might need to adjust the value of `default.api.timeout.ms`; 2. Have MM able to remove offsets for already-deleted topics from `offsets`.
Due to the reason of Point 1 above, I don't think setting `default.api.timeout.ms` to MAX_LONG is reasonable since the introduction of it does give users the ability to get rid of the indefinitely waiting. Does it make any sense? [ Full content available at: https://github.com/apache/kafka/pull/5492 ] This message was relayed via gitbox.apache.org for [email protected]
