This is an automated email from the ASF dual-hosted git repository.
rsivaram pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from e418c53 KAFKA-9363; Display success message after topic creation with
AdminClient (#7893)
add eb09efa KAFKA-7639: Read one request at a time from socket to avoid
OOM (#5920)
No new revisions were added by this update.
Summary of changes:
.../apache/kafka/common/network/Authenticator.java | 21 +-
.../apache/kafka/common/network/KafkaChannel.java | 20 +-
.../common/network/PlaintextChannelBuilder.java | 7 +-
.../apache/kafka/common/network/Selectable.java | 5 +-
.../org/apache/kafka/common/network/Selector.java | 180 +++----
.../authenticator/SaslClientAuthenticator.java | 28 +-
.../apache/kafka/common/network/NioEchoServer.java | 3 +-
.../apache/kafka/common/network/SelectorTest.java | 214 +++++---
.../kafka/common/network/SslSelectorTest.java | 12 +-
.../common/network/SslTransportLayerTest.java | 5 +-
.../authenticator/SaslAuthenticatorTest.java | 2 +-
.../test/java/org/apache/kafka/test/TestUtils.java | 6 +
.../main/scala/kafka/network/SocketServer.scala | 4 -
.../unit/kafka/network/SocketServerTest.scala | 552 +++++++++++++++++----
14 files changed, 740 insertions(+), 319 deletions(-)
