kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmcc...@apache.org
Subject [kafka] branch trunk updated (c87fe94 -> f98013c)
Date Fri, 04 Oct 2019 16:20:09 GMT
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 c87fe94  KAFKA-3705 Added a foreignKeyJoin implementation for KTable. (#5527)
     add f98013c  Part 1 of KIP-511: Collect and Expose Client's Name and Version in the Brokers
#7381

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/kafka/clients/ApiVersion.java  |  56 +++++
 .../org/apache/kafka/clients/NetworkClient.java    |  21 +-
 .../org/apache/kafka/clients/NodeApiVersions.java  |  35 +++-
 .../kafka/clients/consumer/internals/Fetcher.java  |   4 +-
 .../org/apache/kafka/common/protocol/ApiKeys.java  |   6 +-
 .../kafka/common/requests/AbstractResponse.java    |   2 +-
 .../kafka/common/requests/ApiVersionsRequest.java  |  82 +++++---
 .../kafka/common/requests/ApiVersionsResponse.java | 203 ++++++------------
 .../kafka/common/requests/RequestContext.java      |   3 +-
 .../authenticator/SaslClientAuthenticator.java     |  10 +-
 .../authenticator/SaslServerAuthenticator.java     |   4 +-
 .../common/message/ApiVersionsRequest.json         |  10 +-
 .../common/message/ApiVersionsResponse.json        |  14 +-
 .../org/apache/kafka/clients/ApiVersionsTest.java  |   6 +-
 .../apache/kafka/clients/NetworkClientTest.java    | 232 ++++++++++++++++++++-
 .../apache/kafka/clients/NodeApiVersionsTest.java  |  52 +++--
 .../internals/AbstractCoordinatorTest.java         |   4 +-
 .../clients/consumer/internals/FetcherTest.java    |   7 +-
 .../producer/internals/RecordAccumulatorTest.java  |   7 +-
 .../clients/producer/internals/SenderTest.java     |   6 +-
 .../common/requests/ApiVersionsResponseTest.java   |  31 +--
 .../kafka/common/requests/RequestContextTest.java  |  13 +-
 .../kafka/common/requests/RequestResponseTest.java | 112 +++++++++-
 .../authenticator/SaslAuthenticatorTest.java       | 108 ++++++++--
 .../java/org/apache/kafka/test/MockSelector.java   |   7 +
 .../kafka/admin/BrokerApiVersionsCommand.scala     |  10 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |   2 +
 .../unit/kafka/server/ApiVersionsRequestTest.scala |  31 ++-
 .../scala/unit/kafka/server/RequestQuotaTest.scala |   2 +-
 .../kafka/server/SaslApiVersionsRequestTest.scala  |   6 +-
 30 files changed, 782 insertions(+), 304 deletions(-)
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/ApiVersion.java


Mime
View raw message