This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch 2.1
in repository https://gitbox.apache.org/repos/asf/kafka.git.
discard 2379918 MINOR: Make MockClient#poll() more thread-safe (#5942)
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/2.1 (1b74172)
\
O -- O -- O (2379918)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../common/message/AddOffsetsToTxnRequestData.java | 203 ---
.../message/AddOffsetsToTxnResponseData.java | 152 --
.../message/AddPartitionsToTxnRequestData.java | 439 -----
.../message/AddPartitionsToTxnResponseData.java | 561 ------
.../common/message/AlterConfigsRequestData.java | 591 -------
.../common/message/AlterConfigsResponseData.java | 363 ----
.../message/AlterReplicaLogDirsRequestData.java | 576 ------
.../message/AlterReplicaLogDirsResponseData.java | 470 -----
.../kafka/common/message/ApiMessageFactory.java | 406 -----
.../common/message/ApiVersionsRequestData.java | 112 --
.../common/message/ApiVersionsResponseData.java | 421 -----
.../message/ControlledShutdownRequestData.java | 172 --
.../message/ControlledShutdownResponseData.java | 374 ----
.../common/message/CreateAclsRequestData.java | 436 -----
.../common/message/CreateAclsResponseData.java | 318 ----
.../message/CreateDelegationTokenRequestData.java | 321 ----
.../message/CreateDelegationTokenResponseData.java | 311 ----
.../message/CreatePartitionsRequestData.java | 539 ------
.../message/CreatePartitionsResponseData.java | 343 ----
.../common/message/CreateTopicsRequestData.java | 884 ---------
.../common/message/CreateTopicsResponseData.java | 435 -----
.../common/message/DeleteAclsRequestData.java | 442 -----
.../common/message/DeleteAclsResponseData.java | 692 --------
.../common/message/DeleteGroupsRequestData.java | 172 --
.../common/message/DeleteGroupsResponseData.java | 364 ----
.../common/message/DeleteRecordsRequestData.java | 470 -----
.../common/message/DeleteRecordsResponseData.java | 490 -----
.../common/message/DeleteTopicsRequestData.java | 198 ---
.../common/message/DeleteTopicsResponseData.java | 350 ----
.../common/message/DescribeAclsRequestData.java | 301 ----
.../common/message/DescribeAclsResponseData.java | 637 -------
.../common/message/DescribeConfigsRequestData.java | 416 -----
.../message/DescribeConfigsResponseData.java | 918 ----------
.../DescribeDelegationTokenRequestData.java | 317 ----
.../DescribeDelegationTokenResponseData.java | 633 -------
.../common/message/DescribeGroupsRequestData.java | 175 --
.../common/message/DescribeGroupsResponseData.java | 670 -------
.../common/message/DescribeLogDirsRequestData.java | 345 ----
.../message/DescribeLogDirsResponseData.java | 689 --------
.../message/ElectPreferredLeadersRequestData.java | 359 ----
.../message/ElectPreferredLeadersResponseData.java | 488 -----
.../kafka/common/message/EndTxnRequestData.java | 198 ---
.../kafka/common/message/EndTxnResponseData.java | 152 --
.../message/ExpireDelegationTokenRequestData.java | 155 --
.../message/ExpireDelegationTokenResponseData.java | 172 --
.../kafka/common/message/FetchRequestData.java | 1143 ------------
.../kafka/common/message/FetchResponseData.java | 1028 -----------
.../common/message/FindCoordinatorRequestData.java | 183 --
.../message/FindCoordinatorResponseData.java | 282 ---
.../kafka/common/message/HeartbeatRequestData.java | 186 --
.../common/message/HeartbeatResponseData.java | 172 --
.../common/message/InitProducerIdRequestData.java | 160 --
.../common/message/InitProducerIdResponseData.java | 192 --
.../kafka/common/message/JoinGroupRequestData.java | 501 ------
.../common/message/JoinGroupResponseData.java | 474 -----
.../common/message/LeaderAndIsrRequestData.java | 1388 ---------------
.../common/message/LeaderAndIsrResponseData.java | 342 ----
.../common/message/LeaveGroupRequestData.java | 166 --
.../common/message/LeaveGroupResponseData.java | 172 --
.../common/message/ListGroupsRequestData.java | 112 --
.../common/message/ListGroupsResponseData.java | 365 ----
.../common/message/ListOffsetRequestData.java | 650 -------
.../common/message/ListOffsetResponseData.java | 728 --------
.../kafka/common/message/MetadataRequestData.java | 373 ----
.../kafka/common/message/MetadataResponseData.java | 1293 --------------
.../common/message/OffsetCommitRequestData.java | 776 --------
.../common/message/OffsetCommitResponseData.java | 532 ------
.../common/message/OffsetFetchRequestData.java | 398 -----
.../common/message/OffsetFetchResponseData.java | 666 -------
.../message/OffsetForLeaderEpochRequestData.java | 504 ------
.../message/OffsetForLeaderEpochResponseData.java | 562 ------
.../kafka/common/message/ProduceRequestData.java | 600 -------
.../kafka/common/message/ProduceResponseData.java | 656 -------
.../message/RenewDelegationTokenRequestData.java | 155 --
.../message/RenewDelegationTokenResponseData.java | 172 --
.../kafka/common/message/RequestHeaderData.java | 195 --
.../kafka/common/message/ResponseHeaderData.java | 129 --
.../message/SaslAuthenticateRequestData.java | 135 --
.../message/SaslAuthenticateResponseData.java | 227 ---
.../common/message/SaslHandshakeRequestData.java | 138 --
.../common/message/SaslHandshakeResponseData.java | 192 --
.../common/message/StopReplicaRequestData.java | 657 -------
.../common/message/StopReplicaResponseData.java | 336 ----
.../kafka/common/message/SyncGroupRequestData.java | 375 ----
.../common/message/SyncGroupResponseData.java | 196 --
.../common/message/TxnOffsetCommitRequestData.java | 626 -------
.../message/TxnOffsetCommitResponseData.java | 479 -----
.../common/message/UpdateMetadataRequestData.java | 1868 --------------------
.../common/message/UpdateMetadataResponseData.java | 144 --
.../common/message/WriteTxnMarkersRequestData.java | 534 ------
.../message/WriteTxnMarkersResponseData.java | 592 -------
.../java/org/apache/kafka/clients/MockClient.java | 3 +-
.../clients/admin/AdminClientUnitTestEnv.java | 4 -
93 files changed, 1 insertion(+), 39990 deletions(-)
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/AddOffsetsToTxnRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/AddOffsetsToTxnResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/AddPartitionsToTxnRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/AddPartitionsToTxnResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/AlterConfigsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/AlterConfigsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/AlterReplicaLogDirsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/AlterReplicaLogDirsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ApiMessageFactory.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ApiVersionsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ApiVersionsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ControlledShutdownRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ControlledShutdownResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/CreateAclsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/CreateAclsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/CreateDelegationTokenRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/CreateDelegationTokenResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/CreatePartitionsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/CreatePartitionsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/CreateTopicsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/CreateTopicsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DeleteAclsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DeleteAclsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DeleteGroupsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DeleteGroupsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DeleteRecordsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DeleteRecordsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DeleteTopicsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DeleteTopicsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DescribeAclsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DescribeAclsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DescribeConfigsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DescribeConfigsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DescribeDelegationTokenRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DescribeDelegationTokenResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DescribeGroupsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DescribeGroupsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DescribeLogDirsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/DescribeLogDirsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ElectPreferredLeadersRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ElectPreferredLeadersResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/EndTxnRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/EndTxnResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ExpireDelegationTokenRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ExpireDelegationTokenResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/FetchRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/FetchResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/FindCoordinatorRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/FindCoordinatorResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/HeartbeatRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/HeartbeatResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/InitProducerIdRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/InitProducerIdResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/JoinGroupRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/JoinGroupResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/LeaderAndIsrRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/LeaderAndIsrResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/LeaveGroupRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/LeaveGroupResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ListGroupsRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ListGroupsResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ListOffsetRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ListOffsetResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/MetadataRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/MetadataResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/OffsetCommitRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/OffsetCommitResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/OffsetFetchRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/OffsetFetchResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/OffsetForLeaderEpochRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/OffsetForLeaderEpochResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ProduceRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ProduceResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/RenewDelegationTokenRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/RenewDelegationTokenResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/RequestHeaderData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/ResponseHeaderData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/SaslAuthenticateRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/SaslAuthenticateResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/SaslHandshakeRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/SaslHandshakeResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/StopReplicaRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/StopReplicaResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/SyncGroupRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/SyncGroupResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/TxnOffsetCommitRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/TxnOffsetCommitResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/UpdateMetadataRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/UpdateMetadataResponseData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/WriteTxnMarkersRequestData.java
delete mode 100644
clients/src/generated/java/org/apache/kafka/common/message/WriteTxnMarkersResponseData.java
