You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2019/12/13 18:38:59 UTC
[kafka] branch trunk updated (9567921 -> ae38315)

This is an automated email from the ASF dual-hosted git repository.

cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 9567921  MINOR: add UPGRADE_FROM to config docs (#7825)
     add ae38315  KAFKA-8855; Collect and Expose Client's Name and Version in the Brokers (KIP-511 Part 2) (#7749)

No new revisions were added by this update.

Summary of changes:
 .../kafka/common/network/ChannelBuilder.java       |  3 +-
 .../common/network/ChannelMetadataRegistry.java    | 55 +++++++++++++++
 .../kafka/common/network/CipherInformation.java    |  4 +-
 ...pherInformation.java => ClientInformation.java} | 38 +++++-----
 .../network/DefaultChannelMetadataRegistry.java    | 38 +++++-----
 .../apache/kafka/common/network/KafkaChannel.java  | 12 ++--
 .../common/network/PlaintextChannelBuilder.java    |  5 +-
 .../common/network/PlaintextTransportLayer.java    |  6 --
 .../kafka/common/network/SaslChannelBuilder.java   | 24 ++++---
 .../org/apache/kafka/common/network/Selector.java  | 80 +++++++++++++++++++---
 .../kafka/common/network/SslChannelBuilder.java    | 17 +++--
 .../kafka/common/network/SslTransportLayer.java    | 30 +++-----
 .../kafka/common/network/TransportLayer.java       |  7 --
 .../kafka/common/requests/RequestContext.java      |  6 +-
 .../authenticator/SaslServerAuthenticator.java     | 11 ++-
 .../kafka/common/network/KafkaChannelTest.java     |  8 ++-
 .../apache/kafka/common/network/SelectorTest.java  | 58 +++++++++++++++-
 .../kafka/common/network/SslSelectorTest.java      | 11 +--
 .../common/network/SslTransportLayerTest.java      |  5 +-
 .../kafka/common/requests/RequestContextTest.java  |  3 +-
 .../authenticator/SaslAuthenticatorTest.java       |  7 +-
 .../authenticator/SaslServerAuthenticatorTest.java | 66 ++++++++++++++++--
 .../kafka/admin/BrokerApiVersionsCommand.scala     |  4 +-
 .../main/scala/kafka/network/RequestChannel.scala  |  1 +
 .../main/scala/kafka/network/SocketServer.scala    | 17 ++++-
 .../unit/kafka/network/SocketServerTest.scala      | 66 +++++++++++++++++-
 .../security/authorizer/AclAuthorizerTest.scala    |  4 +-
 .../unit/kafka/server/ClientQuotaManagerTest.scala |  3 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    |  3 +-
 .../kafka/server/SaslApiVersionsRequestTest.scala  |  4 +-
 .../server/ThrottledChannelExpirationTest.scala    |  3 +-
 31 files changed, 463 insertions(+), 136 deletions(-)
 create mode 100644 clients/src/main/java/org/apache/kafka/common/network/ChannelMetadataRegistry.java
 copy clients/src/main/java/org/apache/kafka/common/network/{CipherInformation.java => ClientInformation.java} (50%)
 copy streams/src/test/java/org/apache/kafka/test/KeyValueIteratorStub.java => clients/src/main/java/org/apache/kafka/common/network/DefaultChannelMetadataRegistry.java (52%)