From commits-return-13386-apmail-kafka-commits-archive=kafka.apache.org@kafka.apache.org Mon Jan 13 09:44:15 2020 Return-Path: X-Original-To: apmail-kafka-commits-archive@www.apache.org Delivered-To: apmail-kafka-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by minotaur.apache.org (Postfix) with SMTP id 0788919944 for ; Mon, 13 Jan 2020 09:44:14 +0000 (UTC) Received: (qmail 83943 invoked by uid 500); 13 Jan 2020 09:44:14 -0000 Delivered-To: apmail-kafka-commits-archive@kafka.apache.org Received: (qmail 83909 invoked by uid 500); 13 Jan 2020 09:44:13 -0000 Mailing-List: contact commits-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list commits@kafka.apache.org Received: (qmail 83900 invoked by uid 99); 13 Jan 2020 09:44:13 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 13 Jan 2020 09:44:13 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 9C97081F11; Mon, 13 Jan 2020 09:44:13 +0000 (UTC) Date: Mon, 13 Jan 2020 09:44:08 +0000 To: "commits@kafka.apache.org" Subject: [kafka] branch trunk updated (e418c53 -> eb09efa) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <157890864610.2589.1307010117537218598@gitbox.apache.org> From: rsivaram@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: kafka X-Git-Refname: refs/heads/trunk X-Git-Reftype: branch X-Git-Oldrev: e418c53ff7992f6e2906397782c66207714a7b95 X-Git-Newrev: eb09efa9ac79efa484307bdcf03ac8eb8a3a94e2 X-Git-NotificationType: ref_changed X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated 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(-)