You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by rs...@apache.org on 2020/01/13 09:44:08 UTC

[kafka] branch trunk updated (e418c53 -> eb09efa)

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(-)