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%)
