This is an automated email from the ASF dual-hosted git repository.
ijuma pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from ad4211f HOTFIX: Access apiversions data via method not field (#9759)
add 782175d MINOR: Simplify ApiKeys by relying on ApiMessageType (#9748)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/admin/KafkaAdminClient.java | 48 +--
.../kafka/clients/consumer/internals/Fetcher.java | 64 ++--
.../org/apache/kafka/common/protocol/ApiKeys.java | 413 +++++----------------
.../apache/kafka/common/protocol/CommonFields.java | 35 --
.../org/apache/kafka/common/protocol/Errors.java | 2 +
.../org/apache/kafka/common/protocol/Protocol.java | 4 +-
.../kafka/common/requests/AbstractRequest.java | 2 +-
.../kafka/common/requests/AbstractResponse.java | 2 +-
...tOffsetRequest.java => ListOffsetsRequest.java} | 76 ++--
...ffsetResponse.java => ListOffsetsResponse.java} | 26 +-
.../java/org/apache/kafka/common/utils/Utils.java | 10 +-
...tOffsetRequest.json => ListOffsetsRequest.json} | 6 +-
...ffsetResponse.json => ListOffsetsResponse.json} | 6 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 92 ++---
.../kafka/clients/consumer/KafkaConsumerTest.java | 50 +--
.../clients/consumer/internals/FetcherTest.java | 202 +++++-----
.../kafka/common/message/ApiMessageTypeTest.java | 29 ++
.../apache/kafka/common/message/MessageTest.java | 125 +------
.../apache/kafka/common/protocol/ApiKeysTest.java | 9 +-
.../common/requests/ApiVersionsResponseTest.java | 12 +-
...equestTest.java => ListOffsetsRequestTest.java} | 84 ++---
.../common/requests/OffsetFetchResponseTest.java | 3 +-
.../kafka/common/requests/RequestResponseTest.java | 48 +--
.../authenticator/SaslAuthenticatorTest.java | 18 +-
.../scala/kafka/admin/ConsumerGroupCommand.scala | 5 +-
core/src/main/scala/kafka/cluster/Partition.scala | 4 +-
core/src/main/scala/kafka/log/IndexEntry.scala | 4 +-
core/src/main/scala/kafka/log/Log.scala | 15 +-
.../scala/kafka/network/RequestConvertToJson.scala | 4 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 52 +--
.../scala/kafka/server/ReplicaFetcherThread.scala | 14 +-
.../main/scala/kafka/tools/ConsoleConsumer.scala | 17 +-
.../main/scala/kafka/tools/GetOffsetShell.scala | 7 +-
.../kafka/tools/ReplicaVerificationTool.scala | 6 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 10 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 21 +-
core/src/test/scala/unit/kafka/log/LogTest.scala | 14 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 34 +-
.../unit/kafka/server/ListOffsetsRequestTest.scala | 60 +--
.../scala/unit/kafka/server/LogOffsetTest.scala | 50 +--
.../scala/unit/kafka/server/RequestQuotaTest.scala | 8 +-
.../kafka/message/ApiMessageTypeGenerator.java | 17 +-
.../jmh/common/ListOffsetRequestBenchmark.java | 12 +-
43 files changed, 697 insertions(+), 1023 deletions(-)
delete mode 100644
clients/src/main/java/org/apache/kafka/common/protocol/CommonFields.java
rename
clients/src/main/java/org/apache/kafka/common/requests/{ListOffsetRequest.java
=> ListOffsetsRequest.java} (64%)
rename
clients/src/main/java/org/apache/kafka/common/requests/{ListOffsetResponse.java
=> ListOffsetsResponse.java} (80%)
rename clients/src/main/resources/common/message/{ListOffsetRequest.json =>
ListOffsetsRequest.json} (93%)
rename clients/src/main/resources/common/message/{ListOffsetResponse.json =>
ListOffsetsResponse.json} (93%)
rename
clients/src/test/java/org/apache/kafka/common/requests/{ListOffsetRequestTest.java
=> ListOffsetsRequestTest.java} (59%)
