kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated (7349608 -> 0de61a4)
Date Mon, 07 Oct 2019 04:13:58 GMT
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


Mime
View raw message