@vvcephei Note, that we call `waitUntilFinalKeyValueRecordsReceived` now instead of `waitUntilMinKeyValueRecordsReceived`.
@guozhangwang Not sure why we need to update the commit interval? Isn't `auto.commit=false` anyway? If not, should we set `auto.commit=false` instead of setting commit interval to "infinite"? [ Full content available at: https://github.com/apache/kafka/pull/5428 ] This message was relayed via gitbox.apache.org for [email protected]
