This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 99e511c706b KAFKA-16288, KAFKA-16289: Fix Values convertToDecimal
exception and parseString corruption (#15399)
add 47792770a28 KAFKA-16169: FencedException in commitAsync not propagated
without callback (#15437)
No new revisions were added by this update.
Summary of changes:
.../consumer/internals/AsyncKafkaConsumer.java | 15 ++++-
.../consumer/internals/CommitRequestManager.java | 2 +-
.../internals/OffsetCommitCallbackInvoker.java | 10 ----
.../consumer/internals/AsyncKafkaConsumerTest.java | 67 ++++++++++++++++++++++
.../internals/CommitRequestManagerTest.java | 2 -
5 files changed, 80 insertions(+), 16 deletions(-)
