kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmcc...@apache.org
Subject [kafka] branch 2.8 updated (2e16a76 -> e957886)
Date Fri, 19 Feb 2021 00:52:35 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from 2e16a76  TRIVIAL: fix JavaDocs formatting (#10134)
     new 4af420a  Fixed README and added clearer error message. (#10133)
     new e957886  KAFKA-12278; Ensure exposed api versions are consistent within listener
(#10666)

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 checkstyle/import-control.xml                      |   2 +
 .../org/apache/kafka/clients/NodeApiVersions.java  |  10 +-
 .../kafka/common/network/ChannelBuilders.java      |  16 +-
 .../kafka/common/network/SaslChannelBuilder.java   |  12 +-
 .../org/apache/kafka/common/protocol/ApiKeys.java  |  71 ++++++---
 .../org/apache/kafka/common/protocol/Protocol.java |   2 +-
 .../kafka/common/requests/ApiVersionsResponse.java |  89 ++++++++---
 .../authenticator/SaslServerAuthenticator.java     |  13 +-
 .../common/message/AddOffsetsToTxnRequest.json     |   1 +
 .../common/message/AddPartitionsToTxnRequest.json  |   1 +
 .../common/message/AlterClientQuotasRequest.json   |   1 +
 .../common/message/AlterConfigsRequest.json        |   1 +
 .../resources/common/message/AlterIsrRequest.json  |   1 +
 .../AlterPartitionReassignmentsRequest.json        |   1 +
 .../common/message/AlterReplicaLogDirsRequest.json |   1 +
 .../message/AlterUserScramCredentialsRequest.json  |   1 +
 .../common/message/ApiVersionsRequest.json         |   1 +
 .../common/message/BeginQuorumEpochRequest.json    |   1 +
 .../common/message/BrokerHeartbeatRequest.json     |   1 +
 .../common/message/BrokerRegistrationRequest.json  |   1 +
 .../common/message/ControlledShutdownRequest.json  |   1 +
 .../common/message/CreateAclsRequest.json          |   1 +
 .../message/CreateDelegationTokenRequest.json      |   1 +
 .../common/message/CreatePartitionsRequest.json    |   1 +
 .../common/message/CreateTopicsRequest.json        |   1 +
 .../common/message/DeleteAclsRequest.json          |   1 +
 .../common/message/DeleteGroupsRequest.json        |   1 +
 .../common/message/DeleteRecordsRequest.json       |   1 +
 .../common/message/DeleteTopicsRequest.json        |   1 +
 .../common/message/DescribeAclsRequest.json        |   1 +
 .../message/DescribeClientQuotasRequest.json       |   1 +
 .../common/message/DescribeClusterRequest.json     |   1 +
 .../common/message/DescribeConfigsRequest.json     |   1 +
 .../message/DescribeDelegationTokenRequest.json    |   1 +
 .../common/message/DescribeGroupsRequest.json      |   1 +
 .../common/message/DescribeLogDirsRequest.json     |   1 +
 .../common/message/DescribeProducersRequest.json   |   1 +
 .../common/message/DescribeQuorumRequest.json      |   1 +
 .../DescribeUserScramCredentialsRequest.json       |   1 +
 .../common/message/ElectLeadersRequest.json        |   1 +
 .../common/message/EndQuorumEpochRequest.json      |   1 +
 .../resources/common/message/EndTxnRequest.json    |   1 +
 .../resources/common/message/EnvelopeRequest.json  |   1 +
 .../message/ExpireDelegationTokenRequest.json      |   1 +
 .../resources/common/message/FetchRequest.json     |   1 +
 .../common/message/FetchSnapshotRequest.json       |   1 +
 .../common/message/FindCoordinatorRequest.json     |   1 +
 .../resources/common/message/HeartbeatRequest.json |   1 +
 .../message/IncrementalAlterConfigsRequest.json    |   1 +
 .../common/message/InitProducerIdRequest.json      |   1 +
 .../resources/common/message/JoinGroupRequest.json |   1 +
 .../common/message/LeaderAndIsrRequest.json        |   1 +
 .../common/message/LeaveGroupRequest.json          |   1 +
 .../common/message/ListGroupsRequest.json          |   1 +
 .../common/message/ListOffsetsRequest.json         |   1 +
 .../message/ListPartitionReassignmentsRequest.json |   1 +
 .../resources/common/message/MetadataRequest.json  |   1 +
 .../common/message/OffsetCommitRequest.json        |   1 +
 .../common/message/OffsetDeleteRequest.json        |   1 +
 .../common/message/OffsetFetchRequest.json         |   1 +
 .../message/OffsetForLeaderEpochRequest.json       |   1 +
 .../resources/common/message/ProduceRequest.json   |   1 +
 .../message/RenewDelegationTokenRequest.json       |   1 +
 .../common/message/SaslAuthenticateRequest.json    |   1 +
 .../common/message/SaslHandshakeRequest.json       |   1 +
 .../common/message/StopReplicaRequest.json         |   1 +
 .../resources/common/message/SyncGroupRequest.json |   1 +
 .../common/message/TxnOffsetCommitRequest.json     |   1 +
 .../common/message/UnregisterBrokerRequest.json    |   1 +
 .../common/message/UpdateFeaturesRequest.json      |   1 +
 .../common/message/UpdateMetadataRequest.json      |   1 +
 .../main/resources/common/message/VoteRequest.json |   1 +
 .../common/message/WriteTxnMarkersRequest.json     |   1 +
 .../apache/kafka/clients/NetworkClientTest.java    |  17 +-
 .../apache/kafka/clients/NodeApiVersionsTest.java  |  36 +++--
 .../kafka/clients/admin/KafkaAdminClientTest.java  |  14 +-
 .../clients/consumer/internals/FetcherTest.java    |   6 +-
 .../clients/producer/internals/SenderTest.java     |  27 ++--
 .../apache/kafka/common/network/NioEchoServer.java |   5 +-
 .../common/network/SaslChannelBuilderTest.java     |  14 +-
 .../common/network/SslTransportLayerTest.java      |  24 ++-
 .../apache/kafka/common/protocol/ApiKeysTest.java  |  22 ++-
 .../common/requests/ApiVersionsResponseTest.java   |  51 +++---
 .../kafka/common/requests/RequestResponseTest.java | 100 ++++++------
 .../authenticator/SaslAuthenticatorTest.java       | 177 ++++++++++-----------
 .../authenticator/SaslServerAuthenticatorTest.java |   8 +-
 core/src/main/scala/kafka/api/ApiVersion.scala     |  71 ++++-----
 .../main/scala/kafka/network/RequestChannel.scala  |  17 +-
 .../main/scala/kafka/network/SocketServer.scala    |  36 +++--
 .../scala/kafka/server/ApiVersionManager.scala     | 126 +++++++++++++++
 .../src/main/scala/kafka/server/BrokerServer.scala |  51 ++++--
 .../main/scala/kafka/server/ControllerServer.scala |   8 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |  58 ++-----
 .../main/scala/kafka/server/KafkaRaftServer.scala  |  15 +-
 core/src/main/scala/kafka/server/KafkaServer.scala |  40 +++--
 .../scala/kafka/tools/TestRaftRequestHandler.scala |   8 +-
 .../main/scala/kafka/tools/TestRaftServer.scala    |  13 +-
 .../kafka/admin/BrokerApiVersionsCommandTest.scala |   2 +-
 .../kafka/server/GssapiAuthenticationTest.scala    |   5 +-
 .../test/scala/unit/kafka/api/ApiVersionTest.scala |  23 +--
 .../unit/kafka/network/SocketServerTest.scala      |  61 ++++---
 .../server/AbstractApiVersionsRequestTest.scala    |  15 +-
 .../unit/kafka/server/ApiVersionManagerTest.scala  | 115 +++++++++++++
 .../unit/kafka/server/ApiVersionsRequestTest.scala |   8 +-
 .../unit/kafka/server/ForwardingManagerTest.scala  |   3 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    |  85 ++--------
 .../scala/unit/kafka/server/RequestQuotaTest.scala |   6 +-
 .../kafka/server/SaslApiVersionsRequestTest.scala  |   4 +-
 .../kafka/message/ApiMessageTypeGenerator.java     |  69 +++++++-
 .../org/apache/kafka/message/MessageGenerator.java |   6 +-
 .../java/org/apache/kafka/message/MessageSpec.java |  16 +-
 ...auseGenerator.java => RequestListenerType.java} |  17 +-
 .../jmh/metadata/MetadataRequestBenchmark.java     |   8 +-
 raft/README.md                                     |   2 +-
 114 files changed, 1077 insertions(+), 592 deletions(-)
 create mode 100644 core/src/main/scala/kafka/server/ApiVersionManager.scala
 create mode 100644 core/src/test/scala/unit/kafka/server/ApiVersionManagerTest.scala
 copy generator/src/main/java/org/apache/kafka/message/{ClauseGenerator.java => RequestListenerType.java}
(78%)


Mime
View raw message