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
