This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 7349608 MINOR: Gracefully handle non-assigned case in fetcher metric
(#7383)
add 0de61a4 KAFKA-8885; The Kafka Protocol should Support Optional Tagged
Fields (#7325)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../org/apache/kafka/clients/ClientRequest.java | 2 +-
.../org/apache/kafka/clients/NetworkClient.java | 3 +-
.../org/apache/kafka/common/protocol/ApiKeys.java | 18 +-
.../kafka/common/protocol/ByteBufferAccessor.java | 14 +-
.../org/apache/kafka/common/protocol/Message.java | 21 +-
.../apache/kafka/common/protocol/MessageUtil.java | 14 -
.../common/protocol/ObjectSerializationCache.java | 57 +
.../org/apache/kafka/common/protocol/Readable.java | 34 +-
.../org/apache/kafka/common/protocol/Writable.java | 50 +-
.../types/{ArrayOf.java => CompactArrayOf.java} | 58 +-
.../apache/kafka/common/protocol/types/Field.java | 38 +
.../common/protocol/types/RawTaggedField.java | 45 +-
.../protocol/types/RawTaggedFieldWriter.java | 80 ++
.../kafka/common/protocol/types/TaggedFields.java | 181 +++
.../apache/kafka/common/protocol/types/Type.java | 240 +++-
.../kafka/common/requests/AbstractResponse.java | 5 +-
.../kafka/common/requests/ApiVersionsResponse.java | 21 +-
.../kafka/common/requests/LeaderAndIsrRequest.java | 14 +-
.../kafka/common/requests/RequestHeader.java | 7 +-
.../kafka/common/requests/StopReplicaRequest.java | 10 +-
.../common/requests/UpdateMetadataRequest.java | 14 +-
.../authenticator/SaslClientAuthenticator.java | 2 +-
.../common/message/AddOffsetsToTxnRequest.json | 1 +
.../common/message/AddOffsetsToTxnResponse.json | 1 +
.../common/message/AddPartitionsToTxnRequest.json | 1 +
.../common/message/AddPartitionsToTxnResponse.json | 1 +
.../common/message/AlterConfigsRequest.json | 1 +
.../common/message/AlterConfigsResponse.json | 1 +
.../AlterPartitionReassignmentsRequest.json | 1 +
.../AlterPartitionReassignmentsResponse.json | 1 +
.../common/message/AlterReplicaLogDirsRequest.json | 1 +
.../message/AlterReplicaLogDirsResponse.json | 1 +
.../common/message/ApiVersionsRequest.json | 3 +-
.../common/message/ApiVersionsResponse.json | 3 +-
.../common/message/ControlledShutdownRequest.json | 1 +
.../common/message/ControlledShutdownResponse.json | 1 +
.../common/message/CreateAclsRequest.json | 1 +
.../common/message/CreateAclsResponse.json | 1 +
.../message/CreateDelegationTokenRequest.json | 5 +-
.../message/CreateDelegationTokenResponse.json | 5 +-
.../common/message/CreatePartitionsRequest.json | 1 +
.../common/message/CreatePartitionsResponse.json | 1 +
.../common/message/CreateTopicsRequest.json | 7 +-
.../common/message/CreateTopicsResponse.json | 11 +-
.../common/message/DeleteAclsRequest.json | 1 +
.../common/message/DeleteAclsResponse.json | 1 +
.../common/message/DeleteGroupsRequest.json | 5 +-
.../common/message/DeleteGroupsResponse.json | 5 +-
.../common/message/DeleteRecordsRequest.json | 1 +
.../common/message/DeleteRecordsResponse.json | 1 +
.../common/message/DeleteTopicsRequest.json | 5 +-
.../common/message/DeleteTopicsResponse.json | 7 +-
.../common/message/DescribeAclsRequest.json | 1 +
.../common/message/DescribeAclsResponse.json | 1 +
.../common/message/DescribeConfigsRequest.json | 1 +
.../common/message/DescribeConfigsResponse.json | 1 +
.../message/DescribeDelegationTokenRequest.json | 1 +
.../message/DescribeDelegationTokenResponse.json | 1 +
.../common/message/DescribeGroupsRequest.json | 7 +-
.../common/message/DescribeGroupsResponse.json | 8 +-
.../common/message/DescribeLogDirsRequest.json | 1 +
.../common/message/DescribeLogDirsResponse.json | 1 +
.../common/message/ElectLeadersRequest.json | 6 +-
.../common/message/ElectLeadersResponse.json | 6 +-
.../resources/common/message/EndTxnRequest.json | 1 +
.../resources/common/message/EndTxnResponse.json | 1 +
.../message/ExpireDelegationTokenRequest.json | 1 +
.../message/ExpireDelegationTokenResponse.json | 1 +
.../resources/common/message/FetchRequest.json | 1 +
.../resources/common/message/FetchResponse.json | 1 +
.../common/message/FindCoordinatorRequest.json | 6 +-
.../common/message/FindCoordinatorResponse.json | 6 +-
.../resources/common/message/HeartbeatRequest.json | 6 +-
.../common/message/HeartbeatResponse.json | 7 +-
.../message/IncrementalAlterConfigsRequest.json | 4 +-
.../message/IncrementalAlterConfigsResponse.json | 4 +-
.../common/message/InitProducerIdRequest.json | 5 +-
.../common/message/InitProducerIdResponse.json | 5 +-
.../resources/common/message/JoinGroupRequest.json | 8 +-
.../common/message/JoinGroupResponse.json | 9 +-
.../common/message/LeaderAndIsrRequest.json | 1 +
.../common/message/LeaderAndIsrResponse.json | 1 +
.../common/message/LeaveGroupRequest.json | 6 +-
.../common/message/LeaveGroupResponse.json | 7 +-
.../common/message/ListGroupsRequest.json | 5 +-
.../common/message/ListGroupsResponse.json | 6 +-
.../common/message/ListOffsetRequest.json | 5 +
.../common/message/ListOffsetResponse.json | 5 +
.../message/ListPartitionReassignmentsRequest.json | 1 +
.../ListPartitionReassignmentsResponse.json | 1 +
.../resources/common/message/MetadataRequest.json | 6 +-
.../resources/common/message/MetadataResponse.json | 6 +-
.../common/message/OffsetCommitRequest.json | 6 +-
.../common/message/OffsetCommitResponse.json | 6 +-
.../common/message/OffsetFetchRequest.json | 5 +-
.../common/message/OffsetFetchResponse.json | 5 +-
.../message/OffsetForLeaderEpochRequest.json | 3 +
.../message/OffsetForLeaderEpochResponse.json | 1 +
.../resources/common/message/ProduceRequest.json | 3 +-
.../resources/common/message/ProduceResponse.json | 3 +-
.../message/RenewDelegationTokenRequest.json | 1 +
.../message/RenewDelegationTokenResponse.json | 1 +
.../resources/common/message/RequestHeader.json | 5 +-
.../resources/common/message/ResponseHeader.json | 3 +-
.../common/message/SaslAuthenticateRequest.json | 1 +
.../common/message/SaslAuthenticateResponse.json | 1 +
.../common/message/SaslHandshakeRequest.json | 1 +
.../common/message/SaslHandshakeResponse.json | 1 +
.../common/message/StopReplicaRequest.json | 1 +
.../common/message/StopReplicaResponse.json | 1 +
.../resources/common/message/SyncGroupRequest.json | 6 +-
.../common/message/SyncGroupResponse.json | 7 +-
.../common/message/TxnOffsetCommitRequest.json | 1 +
.../common/message/TxnOffsetCommitResponse.json | 1 +
.../common/message/UpdateMetadataRequest.json | 1 +
.../common/message/UpdateMetadataResponse.json | 1 +
.../common/message/WriteTxnMarkersRequest.json | 1 +
.../common/message/WriteTxnMarkersResponse.json | 1 +
.../apache/kafka/clients/NetworkClientTest.java | 6 +-
.../kafka/common/message/ApiMessageTypeTest.java | 21 +
.../apache/kafka/common/message/MessageTest.java | 98 +-
.../common/message/SimpleExampleMessageTest.java | 104 ++
.../kafka/common/message/TestUUIDDataTest.java | 86 --
.../kafka/common/protocol/MessageTestUtil.java} | 37 +-
.../kafka/common/protocol/MessageUtilTest.java | 20 -
.../protocol/types/ProtocolSerializationTest.java | 74 +-
.../protocol/types/RawTaggedFieldWriterTest.java | 99 ++
.../common/requests/LeaderAndIsrRequestTest.java | 8 +-
.../kafka/common/requests/RequestContextTest.java | 3 +-
.../kafka/common/requests/RequestHeaderTest.java | 10 +
.../kafka/common/requests/RequestResponseTest.java | 17 +-
.../common/requests/StopReplicaRequestTest.java | 4 +-
.../common/requests/UpdateMetadataRequestTest.java | 6 +-
.../authenticator/SaslAuthenticatorTest.java | 16 +-
.../common/message/SimpleExampleMessage.json} | 10 +-
.../test/resources/common/message/TestUUID.json | 22 -
.../unit/kafka/server/ApiVersionsRequestTest.scala | 6 +-
.../scala/unit/kafka/server/BaseRequestTest.scala | 14 +-
.../unit/kafka/server/EdgeCaseRequestTest.scala | 6 +-
.../scala/unit/kafka/server/FetchRequestTest.scala | 4 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 2 +-
.../kafka/message/ApiMessageTypeGenerator.java | 72 +
.../java/org/apache/kafka/message/FieldSpec.java | 95 +-
.../apache/kafka/message/MessageDataGenerator.java | 1464 +++++++++++++-------
.../org/apache/kafka/message/MessageGenerator.java | 34 +
.../java/org/apache/kafka/message/MessageSpec.java | 25 +-
.../org/apache/kafka/message/SchemaGenerator.java | 111 +-
.../java/org/apache/kafka/message/StructSpec.java | 29 +-
.../apache/kafka/message/VersionConditional.java | 12 +-
.../kafka/message/MessageDataGeneratorTest.java | 194 ++-
.../kafka/message/VersionConditionalTest.java | 14 +-
152 files changed, 2973 insertions(+), 974 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/common/protocol/ObjectSerializationCache.java
copy
clients/src/main/java/org/apache/kafka/common/protocol/types/{ArrayOf.java =>
CompactArrayOf.java} (68%)
copy tools/src/main/java/org/apache/kafka/trogdor/rest/Empty.java =>
clients/src/main/java/org/apache/kafka/common/protocol/types/RawTaggedField.java
(57%)
create mode 100644
clients/src/main/java/org/apache/kafka/common/protocol/types/RawTaggedFieldWriter.java
create mode 100644
clients/src/main/java/org/apache/kafka/common/protocol/types/TaggedFields.java
create mode 100644
clients/src/test/java/org/apache/kafka/common/message/SimpleExampleMessageTest.java
delete mode 100644
clients/src/test/java/org/apache/kafka/common/message/TestUUIDDataTest.java
copy
clients/src/{main/java/org/apache/kafka/common/utils/ByteBufferInputStream.java
=> test/java/org/apache/kafka/common/protocol/MessageTestUtil.java} (52%)
create mode 100644
clients/src/test/java/org/apache/kafka/common/protocol/types/RawTaggedFieldWriterTest.java
copy clients/src/{main/resources/common/message/ResponseHeader.json =>
test/resources/common/message/SimpleExampleMessage.json} (78%)
delete mode 100644 clients/src/test/resources/common/message/TestUUID.json
