@guozhangwang Thanks for that catch. I failed to add the extra parameter to the javadoc for the second method. The semantics are basically the same. The first one defaults to an unbounded buffer.
In retrospect, this seems like an unnecessary shortcut. I think I'll just ditch the first method and document the buffer config on the second. [ Full content available at: https://github.com/apache/kafka/pull/5567 ] This message was relayed via gitbox.apache.org for [email protected]
