This is an automated email from the ASF dual-hosted git repository.
dajac pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 1e09165 KAFKA-13117: migrate TupleForwarder and CacheFlushListener to
new Record API (#11481)
add 28dcbad KAFKA-13457: SocketChannel in Acceptor#accept is not closed
upon IOException (#11504)
No new revisions were added by this update.
Summary of changes:
.../main/scala/kafka/network/SocketServer.scala | 22 +++++++++-----
.../unit/kafka/network/SocketServerTest.scala | 35 ++++++++++++++++++++++
2 files changed, 50 insertions(+), 7 deletions(-)
