This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch kafka-10866-consumerrecords-metadata
in repository https://gitbox.apache.org/repos/asf/kafka.git.
omit ba6eb4a drop beginningOffset from the metadata
omit ddef3d1 Rollback consumer-side metadata caching
omit 86e267b Consumer changes to cope with cached metadata response
omit 7d7f19f spotbugs
omit 667ec8e fix test
omit 0cd4af0 fix core integration test failures
omit dc27e3f tests
omit ecb1de1 KAFKA-10866: Add fetched metadata to ConsumerRecords
add e3ce4a6 KAFKA-10870; Handle REBALANCE_IN_PROGRESS error in JoinGroup
(#9792)
add c9afd2d MINOR: refactor FetchResponse#toMessage to avoid creating
unnecessary collections (#9818)
add bf694b2 MINOR: Add 2.7.0 release to broker and client compat tests
(#9774)
add daad1cb KAFKA-10894; Ensure PartitionInfo replicas are not null in
client quota callback (#9802)
add fa1e456 MINOR: Add a few missing entity type tags (#9828)
add b80cf9c MINOR: make sure all dir jobs are completed (#9728)
add ea2423e MINOR: Update log statements in
alterBrokerConfigs/alterTopicConfigs methods
add df9fc38 MINOR: Combine repeated top-level error test in
AlterIsrManagerTest (#9649)
add bf55afe KAFKA-10778; Fence appends after write failure (#9676)
add 2e0c686 MINOR: improve KafkaStreams replication factor documentation
(#9829)
add 2552aa3 KAFKA-10671: improve the partition.assignment.strategy docs
(#9788)
add 3931390 MINOR: code cleanup for Kafka Streams task interface (#9801)
add 22e8e71 KAFKA-9274: Fix commit-TimeoutException handling for EOS
(#9800)
add 71540c0 KAFKA-10874: Fix flaky
ClientQuotasRequestTest.testAlterIpQuotasRequest (#9778)
add f0ef578 MINOR: Add a log to print acl change notification details
add 52652a0 KAFKA-10779; Reassignment tool sets throttles incorrectly
when overriding a reassignment (#9807)
add 94f9b91 KAFKA-9566: Improve DeserializationExceptionHandler JavaDocs
(#9837)
add e5733f3 MINOR: revise error message from
TransactionalRequestResult#await (#9843)
add 8716ba1 MINOR; Add producer id in exceptions thrown by
ProducerStateManager (#9827)
add 689bb7d KAFKA-12165: Include org.apache.kafka.common.quota in javadoc
(#9846)
add ea459d1 KAFKA-12153; Update producer state before updating start/end
offsets after truncation (#9838)
add f06dff1 KAFKA-10887 Migrate log4j-appender module to JUnit 5 (#9785)
add 3697390 KAFKA-10878 Check failed message in ProtocolSerializationTest
(#9776)
add 913a019 MINOR: replace test "expected" parameter by assertThrows
(#9520)
add 119a2d9 MINOR: Substitute assertEquals(null) with assertNull (#9852)
add 33fcc83 MINOR: Remove unnecessary semicolon in NetworkClient (#9853)
add 39a9274 KAFKA-12156: Document single threaded response handling in
Admin client (#9842)
add f62c2b2 MINOR: Factor `RaftManager` out of `TestRaftServer` (#9839)
add aedb53a KAFKA-10500: Add KafkaStreams#removeStreamThread (#9695)
add 7455b70 KAFKA-10895: Attempt to prevent JAAS config from being
overwritten for basic auth filter in Connect (#9806)
add 1e4d335 KAFKA-12180: Implement the KIP-631 message generator changes
add 474ad1e KAFKA-12168; Move envelope request parsing out of
SocketServer (#9850)
add bed4c6a KAFKA-12172 Migrate streams:examples module to JUnit 5 (#9857)
add 2996642 MINOR: Fix error message in SnapshotWriter.java (#9862)
add 1ad7cea1 MINOR: Remove unnecessary assertDoesNotThrow (#9854)
add 94a0aac MINOR: Add restoration time tracking (#9830)
add ee5ef89 MINOR: Fix flaky test
shouldQuerySpecificActivePartitionStores (#9873)
add ee08b0b Only schedule AlterIsr thread when we have an ISR change
(#9749)
add fec6831 MINOR: reduce StreamThread INFO logging during low traffic
(#9875)
add 52b8aa0 KAFKA-7340: Migrate clients module to JUnit 5 (#9874)
add 04827da KAFKA-12171: Migrate streams:test-utils module to JUnit 5
(#9856)
add 2896a4b MINOR: Rename examples to example (#9886)
add 2746af4 MINOR: replace NotLeaderForPartitionException with
NotLeaderOrFollowerException (#9885)
add 966e9dd MINOR: Updating files with release 2.6.1 (#9844)
add fa66ece MINOR: Make JUnit 5 the default for new projects (#9882)
add 06aa9c5 MINOR: Fix typo in `shouldUseJUnit5` in build.gradle (#9893)
add 2cde6f6 KAFKA-10304: Refactor MM2 integration tests (#9224)
add 217334b KAFKA-12183: Add the KIP-631 metadata record definitions
(#9876)
add 4a985b5 MINOR: fix typo in TimeIndex (#9834)
add a68c141 KAFKA-12201: Migrate connect:basic-auth-extensio module to
JUnit 5 (#9892)
add c49f660 MINOR: Initialize QuorumState lazily in
RaftClient.initialize() (#9881)
add 612ca95 MINOR: Fix StreamsOptimizedTest
add ce6b13d KAFKA-10866: Add fetched metadata to ConsumerRecords
add 2b45771 tests
add 94b35e9 fix core integration test failures
add d78118e fix test
add c0a02f9 spotbugs
add d4edf3c Consumer changes to cope with cached metadata response
add 7e0d558 Rollback consumer-side metadata caching
add 552131c drop beginningOffset from the metadata
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (ba6eb4a)
\
N -- N -- N refs/heads/kafka-10866-consumerrecords-metadata
(552131c)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
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:
.gitignore | 1 +
build.gradle | 74 +-
checkstyle/import-control.xml | 19 +
checkstyle/suppressions.xml | 5 +-
.../org/apache/kafka/clients/NetworkClient.java | 2 +-
.../java/org/apache/kafka/clients/admin/Admin.java | 9 +-
.../kafka/clients/consumer/ConsumerConfig.java | 23 +-
.../consumer/internals/AbstractCoordinator.java | 4 +
.../internals/TransactionalRequestResult.java | 2 +-
.../main/java/org/apache/kafka/common/Cluster.java | 4 +-
.../errors/PrincipalDeserializationException.java | 5 +
.../kafka/common/metrics/stats/TokenBucket.java | 2 +-
.../apache/kafka/common/protocol/MessageUtil.java | 9 +
.../org/apache/kafka/common/protocol/Readable.java | 4 +
.../org/apache/kafka/common/protocol/Writable.java | 6 +
.../apache/kafka/common/protocol/types/Field.java | 6 +
.../apache/kafka/common/protocol/types/Struct.java | 20 +
.../apache/kafka/common/protocol/types/Type.java | 38 +
.../apache/kafka/common/requests/FetchRequest.java | 25 -
.../kafka/common/requests/FetchResponse.java | 39 +-
.../java/org/apache/kafka/common/utils/Utils.java | 18 +-
.../common/message/OffsetDeleteRequest.json | 4 +-
.../common/message/OffsetDeleteResponse.json | 2 +-
.../common/message/TxnOffsetCommitRequest.json | 2 +-
.../org/apache/kafka/clients/ApiVersionsTest.java | 4 +-
.../org/apache/kafka/clients/ClientUtilsTest.java | 35 +-
.../kafka/clients/ClusterConnectionStatesTest.java | 18 +-
.../kafka/clients/CommonClientConfigsTest.java | 4 +-
.../kafka/clients/FetchSessionHandlerTest.java | 25 +-
.../apache/kafka/clients/InFlightRequestsTest.java | 17 +-
.../apache/kafka/clients/MetadataCacheTest.java | 8 +-
.../org/apache/kafka/clients/MetadataTest.java | 34 +-
.../java/org/apache/kafka/clients/MockClient.java | 7 +-
.../apache/kafka/clients/NetworkClientTest.java | 92 +--
.../apache/kafka/clients/NodeApiVersionsTest.java | 29 +-
.../org/apache/kafka/clients/admin/ConfigTest.java | 61 +-
.../DeleteConsumerGroupOffsetsResultTest.java | 12 +-
.../DescribeUserScramCredentialsResultTest.java | 12 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 216 +++--
.../kafka/clients/admin/MemberDescriptionTest.java | 6 +-
.../RemoveMembersFromConsumerGroupOptionsTest.java | 6 +-
.../RemoveMembersFromConsumerGroupResultTest.java | 12 +-
.../admin/internals/AdminMetadataManagerTest.java | 18 +-
.../kafka/clients/consumer/ConsumerConfigTest.java | 8 +-
.../consumer/ConsumerGroupMetadataTest.java | 10 +-
.../kafka/clients/consumer/ConsumerRecordTest.java | 4 +-
.../clients/consumer/ConsumerRecordsTest.java | 4 +-
.../consumer/CooperativeStickyAssignorTest.java | 11 +-
.../kafka/clients/consumer/KafkaConsumerTest.java | 156 ++--
.../kafka/clients/consumer/MockConsumerTest.java | 34 +-
.../clients/consumer/OffsetAndMetadataTest.java | 9 +-
.../kafka/clients/consumer/RangeAssignorTest.java | 10 +-
.../clients/consumer/RoundRobinAssignorTest.java | 6 +-
.../kafka/clients/consumer/StickyAssignorTest.java | 10 +-
.../internals/AbstractCoordinatorTest.java | 55 +-
.../internals/AbstractPartitionAssignorTest.java | 4 +-
.../internals/AbstractStickyAssignorTest.java | 50 +-
.../internals/ConsumerCoordinatorTest.java | 117 ++-
.../internals/ConsumerInterceptorsTest.java | 8 +-
.../consumer/internals/ConsumerMetadataTest.java | 8 +-
.../internals/ConsumerNetworkClientTest.java | 23 +-
.../consumer/internals/ConsumerProtocolTest.java | 10 +-
.../CooperativeConsumerCoordinatorTest.java} | 12 +-
.../internals/EagerConsumerCoordinatorTest.java} | 13 +-
.../clients/consumer/internals/FetcherTest.java | 138 ++--
.../clients/consumer/internals/HeartbeatTest.java | 12 +-
.../internals/OffsetForLeaderEpochClientTest.java | 8 +-
.../internals/PartitionAssignorAdapterTest.java | 8 +-
.../consumer/internals/RequestFutureTest.java | 37 +-
.../consumer/internals/SubscriptionStateTest.java | 39 +-
.../kafka/clients/producer/KafkaProducerTest.java | 49 +-
.../kafka/clients/producer/MockProducerTest.java | 211 ++---
.../kafka/clients/producer/ProducerConfigTest.java | 4 +-
.../kafka/clients/producer/ProducerRecordTest.java | 8 +-
.../kafka/clients/producer/RecordMetadataTest.java | 6 +-
.../kafka/clients/producer/RecordSendTest.java | 17 +-
.../producer/RoundRobinPartitionerTest.java | 10 +-
.../producer/UniformStickyPartitionerTest.java | 12 +-
.../clients/producer/internals/BufferPoolTest.java | 58 +-
.../producer/internals/DefaultPartitionerTest.java | 6 +-
.../internals/FutureRecordMetadataTest.java | 2 +-
.../producer/internals/ProducerBatchTest.java | 24 +-
.../internals/ProducerInterceptorsTest.java | 4 +-
.../producer/internals/ProducerMetadataTest.java | 48 +-
.../producer/internals/RecordAccumulatorTest.java | 181 ++---
.../clients/producer/internals/SenderTest.java | 158 ++--
.../internals/StickyPartitionCacheTest.java | 6 +-
.../producer/internals/TransactionManagerTest.java | 89 +-
.../java/org/apache/kafka/common/ClusterTest.java | 6 +-
.../org/apache/kafka/common/KafkaFutureTest.java | 40 +-
.../org/apache/kafka/common/PartitionInfoTest.java | 9 +-
.../apache/kafka/common/TopicPartitionTest.java | 10 +-
.../java/org/apache/kafka/common/UuidTest.java | 6 +-
.../apache/kafka/common/acl/AclBindingTest.java | 28 +-
.../apache/kafka/common/acl/AclOperationTest.java | 21 +-
.../kafka/common/acl/AclPermissionTypeTest.java | 18 +-
.../common/acl/ResourcePatternFilterTest.java | 8 +-
.../kafka/common/acl/ResourcePatternTest.java | 24 +-
.../apache/kafka/common/cache/LRUCacheTest.java | 6 +-
.../kafka/common/config/AbstractConfigTest.java | 20 +-
.../apache/kafka/common/config/ConfigDefTest.java | 42 +-
.../kafka/common/config/ConfigResourceTest.java | 8 +-
.../kafka/common/config/ConfigTransformerTest.java | 12 +-
.../kafka/common/config/SaslConfigsTest.java | 37 +-
.../provider/DirectoryConfigProviderTest.java | 22 +-
.../config/provider/FileConfigProviderTest.java | 23 +-
.../config/provider/MockFileConfigProvider.java | 4 +-
.../apache/kafka/common/feature/FeaturesTest.java | 12 +-
.../common/feature/FinalizedVersionRangeTest.java | 8 +-
.../common/feature/SupportedVersionRangeTest.java | 10 +-
.../common/header/internals/RecordHeadersTest.java | 14 +-
.../common/internals/PartitionStatesTest.java | 4 +-
.../apache/kafka/common/internals/TopicTest.java | 8 +-
.../memory/GarbageCollectedMemoryPoolTest.java | 143 ++--
.../kafka/common/message/ApiMessageTypeTest.java | 29 +-
.../apache/kafka/common/message/MessageTest.java | 51 +-
.../kafka/common/message/RecordsSerdeTest.java | 6 +-
.../common/message/SimpleExampleMessageTest.java | 34 +-
.../kafka/common/metrics/JmxReporterTest.java | 8 +-
.../kafka/common/metrics/KafkaMbeanTest.java | 44 +-
.../common/metrics/KafkaMetricsContextTest.java | 14 +-
.../apache/kafka/common/metrics/MetricsTest.java | 137 ++--
.../apache/kafka/common/metrics/SensorTest.java | 28 +-
.../kafka/common/metrics/TokenBucketTest.java | 8 +-
.../metrics/internals/IntGaugeSuiteTest.java | 6 +-
.../common/metrics/internals/MetricsUtilsTest.java | 6 +-
.../common/metrics/stats/FrequenciesTest.java | 31 +-
.../kafka/common/metrics/stats/HistogramTest.java | 78 +-
.../kafka/common/metrics/stats/MeterTest.java | 4 +-
.../kafka/common/network/ChannelBuildersTest.java | 10 +-
.../kafka/common/network/KafkaChannelTest.java | 12 +-
.../kafka/common/network/NetworkReceiveTest.java | 8 +-
.../kafka/common/network/NetworkTestUtils.java | 8 +-
.../apache/kafka/common/network/NioEchoServer.java | 8 +-
.../common/network/SaslChannelBuilderTest.java | 16 +-
.../apache/kafka/common/network/SelectorTest.java | 124 ++-
.../kafka/common/network/SslSelectorTest.java | 33 +-
.../common/network/SslTransportLayerTest.java | 894 +++++++++++----------
.../common/network/SslTransportTls12Tls13Test.java | 12 +-
.../network/SslVersionsTransportLayerTest.java | 71 +-
.../apache/kafka/common/protocol/ApiKeysTest.java | 19 +-
.../apache/kafka/common/protocol/ErrorsTest.java | 20 +-
.../kafka/common/protocol/MessageUtilTest.java | 19 +-
.../kafka/common/protocol/ProtoUtilsTest.java | 20 +-
.../kafka/common/protocol/SendBuilderTest.java | 2 +-
.../protocol/types/ProtocolSerializationTest.java | 42 +-
.../protocol/types/RawTaggedFieldWriterTest.java | 14 +-
.../kafka/common/protocol/types/StructTest.java | 6 +-
.../kafka/common/protocol/types/TypeTest.java | 8 +-
.../record/AbstractLegacyRecordBatchTest.java | 33 +-
.../kafka/common/record/BufferSupplierTest.java | 6 +-
.../record/ByteBufferLogInputStreamTest.java | 27 +-
.../record/CompressionRatioEstimatorTest.java | 4 +-
.../kafka/common/record/CompressionTypeTest.java | 6 +-
.../kafka/common/record/ControlRecordTypeTest.java | 4 +-
.../common/record/ControlRecordUtilsTest.java | 15 +-
.../common/record/DefaultRecordBatchTest.java | 45 +-
.../kafka/common/record/DefaultRecordTest.java | 123 +--
.../common/record/EndTransactionMarkerTest.java | 24 +-
.../common/record/FileLogInputStreamTest.java | 115 ++-
.../kafka/common/record/FileRecordsTest.java | 115 +--
.../apache/kafka/common/record/KafkaLZ4Test.java | 239 +++---
.../record/LazyDownConversionRecordsTest.java | 183 ++---
.../kafka/common/record/LegacyRecordTest.java | 142 ++--
.../common/record/MemoryRecordsBuilderTest.java | 466 ++++++-----
.../kafka/common/record/MemoryRecordsTest.java | 265 +++---
.../kafka/common/record/MultiRecordsSendTest.java | 6 +-
.../common/record/SimpleLegacyRecordTest.java | 26 +-
.../kafka/common/replica/ReplicaSelectorTest.java | 14 +-
.../requests/AddPartitionsToTxnRequestTest.java | 4 +-
.../requests/AddPartitionsToTxnResponseTest.java | 8 +-
.../requests/AlterReplicaLogDirsRequestTest.java | 4 +-
.../requests/AlterReplicaLogDirsResponseTest.java | 4 +-
.../common/requests/ApiVersionsResponseTest.java | 34 +-
.../common/requests/ByteBufferChannelTest.java | 2 +-
.../requests/ControlledShutdownRequestTest.java | 6 +-
.../common/requests/CreateAclsRequestTest.java | 15 +-
.../common/requests/DeleteAclsRequestTest.java | 8 +-
.../common/requests/DeleteAclsResponseTest.java | 6 +-
.../common/requests/DeleteGroupsResponseTest.java | 9 +-
.../common/requests/DescribeAclsRequestTest.java | 6 +-
.../common/requests/DescribeAclsResponseTest.java | 15 +-
.../kafka/common/requests/EndTxnRequestTest.java | 4 +-
.../kafka/common/requests/EndTxnResponseTest.java | 4 +-
.../kafka/common/requests/EnvelopeRequestTest.java | 4 +-
.../common/requests/HeartbeatRequestTest.java | 18 +-
.../common/requests/JoinGroupRequestTest.java | 25 +-
.../common/requests/LeaderAndIsrRequestTest.java | 10 +-
.../common/requests/LeaderAndIsrResponseTest.java | 6 +-
.../common/requests/LeaveGroupRequestTest.java | 18 +-
.../common/requests/LeaveGroupResponseTest.java | 12 +-
.../common/requests/ListOffsetsRequestTest.java | 6 +-
.../kafka/common/requests/MetadataRequestTest.java | 10 +-
.../common/requests/OffsetCommitRequestTest.java | 10 +-
.../common/requests/OffsetCommitResponseTest.java | 8 +-
.../common/requests/OffsetFetchRequestTest.java | 20 +-
.../common/requests/OffsetFetchResponseTest.java | 12 +-
.../requests/OffsetsForLeaderEpochRequestTest.java | 6 +-
.../kafka/common/requests/ProduceRequestTest.java | 14 +-
.../kafka/common/requests/ProduceResponseTest.java | 20 +-
.../kafka/common/requests/RequestContextTest.java | 8 +-
.../kafka/common/requests/RequestHeaderTest.java | 4 +-
.../kafka/common/requests/RequestResponseTest.java | 73 +-
.../common/requests/StopReplicaRequestTest.java | 10 +-
.../common/requests/StopReplicaResponseTest.java | 6 +-
.../common/requests/SyncGroupRequestTest.java | 18 +-
.../requests/TxnOffsetCommitRequestTest.java | 12 +-
.../requests/TxnOffsetCommitResponseTest.java | 4 +-
.../common/requests/UpdateFeaturesRequestTest.java | 4 +-
.../requests/UpdateFeaturesResponseTest.java | 4 +-
.../common/requests/UpdateMetadataRequestTest.java | 8 +-
.../requests/WriteTxnMarkersRequestTest.java | 8 +-
.../requests/WriteTxnMarkersResponseTest.java | 8 +-
.../kafka/common/resource/ResourceFilterTest.java | 8 +-
.../kafka/common/resource/ResourceTypeTest.java | 20 +-
.../kafka/common/security/JaasContextTest.java | 25 +-
.../kafka/common/security/SaslExtensionsTest.java | 13 +-
.../auth/DefaultKafkaPrincipalBuilderTest.java | 4 +-
.../common/security/auth/KafkaPrincipalTest.java | 9 +-
.../ClientAuthenticationFailureTest.java | 12 +-
.../security/authenticator/LoginManagerTest.java | 16 +-
.../SaslAuthenticatorFailureDelayTest.java | 45 +-
.../SaslAuthenticatorFailureNoDelayTest.java} | 13 +-
...SaslAuthenticatorFailurePositiveDelayTest.java} | 13 +-
.../authenticator/SaslAuthenticatorTest.java | 79 +-
.../authenticator/SaslServerAuthenticatorTest.java | 12 +-
.../common/security/kerberos/KerberosNameTest.java | 8 +-
.../common/security/kerberos/KerberosRuleTest.java | 6 +-
...OAuthBearerExtensionsValidatorCallbackTest.java | 13 +-
.../oauthbearer/OAuthBearerLoginModuleTest.java | 12 +-
.../OAuthBearerSaslClienCallbackHandlerTest.java | 20 +-
.../oauthbearer/OAuthBearerTokenCallbackTest.java | 8 +-
.../OAuthBearerValidatorCallbackTest.java | 10 +-
.../OAuthBearerClientInitialResponseTest.java | 11 +-
.../internals/OAuthBearerSaslClientTest.java | 6 +-
.../internals/OAuthBearerSaslServerTest.java | 39 +-
.../ExpiringCredentialRefreshConfigTest.java | 6 +-
.../ExpiringCredentialRefreshingLoginTest.java | 8 +-
.../unsecured/OAuthBearerScopeUtilsTest.java | 6 +-
.../unsecured/OAuthBearerUnsecuredJwsTest.java | 19 +-
...uthBearerUnsecuredLoginCallbackHandlerTest.java | 23 +-
...earerUnsecuredValidatorCallbackHandlerTest.java | 8 +-
.../unsecured/OAuthBearerValidationUtilsTest.java | 24 +-
.../plain/internals/PlainSaslServerTest.java | 16 +-
.../scram/internals/ScramCredentialUtilsTest.java | 44 +-
.../scram/internals/ScramFormatterTest.java | 6 +-
.../scram/internals/ScramMessagesTest.java | 22 +-
.../scram/internals/ScramSaslServerTest.java | 20 +-
.../security/ssl/DefaultSslEngineFactoryTest.java | 40 +-
.../kafka/common/security/ssl/SslFactoryTest.java | 123 ++-
.../security/ssl/SslPrincipalMapperTest.java | 6 +-
.../ssl/Tls12SslFactoryTest.java} | 10 +-
.../common/security/ssl/Tls13SslFactoryTest.java} | 11 +-
.../common/serialization/SerializationTest.java | 54 +-
.../kafka/common/utils/AbstractIteratorTest.java | 15 +-
.../kafka/common/utils/AppInfoParserTest.java | 18 +-
.../common/utils/ByteBufferInputStreamTest.java | 6 +-
.../common/utils/ByteBufferOutputStreamTest.java | 6 +-
.../kafka/common/utils/ByteBufferUnmapperTest.java | 2 +-
.../apache/kafka/common/utils/ByteUtilsTest.java | 15 +-
.../org/apache/kafka/common/utils/BytesTest.java | 8 +-
.../apache/kafka/common/utils/ChecksumsTest.java | 8 +-
.../kafka/common/utils/CircularIteratorTest.java | 15 +-
.../kafka/common/utils/CollectionUtilsTest.java | 8 +-
.../apache/kafka/common/utils/ConfigUtilsTest.java | 22 +-
.../org/apache/kafka/common/utils/Crc32CTest.java | 8 +-
.../org/apache/kafka/common/utils/Crc32Test.java | 8 +-
.../org/apache/kafka/common/utils/ExitTest.java | 4 +-
.../kafka/common/utils/ExponentialBackoffTest.java | 6 +-
.../kafka/common/utils/FixedOrderMapTest.java | 36 +-
.../kafka/common/utils/FlattenedIteratorTest.java | 4 +-
.../utils/ImplicitLinkedHashCollectionTest.java | 49 +-
.../ImplicitLinkedHashMultiCollectionTest.java | 39 +-
.../org/apache/kafka/common/utils/JavaTest.java | 16 +-
.../common/utils/LoggingSignalHandlerTest.java | 2 +-
.../kafka/common/utils/MappedIteratorTest.java | 4 +-
.../apache/kafka/common/utils/MockTimeTest.java | 11 +-
.../apache/kafka/common/utils/SanitizerTest.java | 8 +-
.../kafka/common/utils/SecurityUtilsTest.java | 20 +-
.../org/apache/kafka/common/utils/ShellTest.java | 32 +-
.../apache/kafka/common/utils/ThreadUtilsTest.java | 6 +-
.../org/apache/kafka/common/utils/TimeTest.java | 8 +-
.../org/apache/kafka/common/utils/TimerTest.java | 8 +-
.../org/apache/kafka/common/utils/UtilsTest.java | 118 ++-
.../common/message/SimpleExampleMessage.json | 3 +-
.../connector/ConnectorReconfigurationTest.java | 6 +-
.../kafka/connect/data/ConnectSchemaTest.java | 116 +--
.../org/apache/kafka/connect/data/DateTest.java | 16 +-
.../kafka/connect/data/SchemaBuilderTest.java | 104 ++-
.../kafka/connect/data/SchemaProjectorTest.java | 10 +-
.../org/apache/kafka/connect/data/StructTest.java | 30 +-
.../org/apache/kafka/connect/data/TimeTest.java | 16 +-
.../apache/kafka/connect/data/TimestampTest.java | 11 +-
.../org/apache/kafka/connect/data/ValuesTest.java | 32 +-
.../kafka/connect/header/ConnectHeadersTest.java | 5 +-
.../kafka/connect/storage/StringConverterTest.java | 7 +-
.../kafka/connect/util/ConnectorUtilsTest.java | 6 +-
.../extension/BasicAuthSecurityRestExtension.java | 7 +-
.../basic/auth/extension/JaasBasicAuthFilter.java | 16 +-
.../BasicAuthSecurityRestExtensionTest.java | 66 ++
.../auth/extension/JaasBasicAuthFilterTest.java | 179 ++---
.../file/FileStreamSourceConnectorTest.java | 17 +-
.../connect/file/FileStreamSourceTaskTest.java | 9 +-
.../kafka/connect/json/JsonConverterTest.java | 5 +-
.../kafka/connect/mirror/MirrorMakerConfig.java | 4 +-
.../mirror/MirrorConnectorsIntegrationTest.java | 595 --------------
.../org/apache/kafka/connect/mirror/TestUtils.java | 11 +
.../MirrorConnectorsIntegrationBaseTest.java | 601 ++++++++++++++
.../MirrorConnectorsIntegrationSSLTest.java | 67 ++
.../MirrorConnectorsIntegrationTest.java | 11 +-
.../connect/converters/ByteArrayConverterTest.java | 11 +-
.../connect/converters/NumberConverterTest.java | 20 +-
.../kafka/connect/runtime/AbstractHerderTest.java | 36 +-
.../kafka/connect/runtime/ConnectMetricsTest.java | 6 +-
.../kafka/connect/runtime/ConnectorConfigTest.java | 4 +-
.../kafka/connect/runtime/WorkerConfigTest.java | 8 +-
.../kafka/connect/runtime/WorkerSinkTaskTest.java | 2 +-
.../connect/runtime/WorkerSourceTaskTest.java | 13 +-
.../WorkerSourceTaskWithTopicCreationTest.java | 38 +-
.../apache/kafka/connect/runtime/WorkerTest.java | 13 +-
.../runtime/WorkerWithTopicCreationTest.java | 15 +-
.../runtime/distributed/DistributedConfigTest.java | 16 +-
.../connect/runtime/errors/ErrorReporterTest.java | 5 +-
.../errors/RetryWithToleranceOperatorTest.java | 23 +-
.../isolation/DelegatingClassLoaderTest.java | 5 +-
.../connect/runtime/isolation/PluginsTest.java | 11 +-
.../runtime/rest/InternalRequestSignatureTest.java | 15 +-
.../resources/ConnectorPluginsResourceTest.java | 74 +-
.../rest/resources/ConnectorsResourceTest.java | 57 +-
.../rest/resources/LoggingResourceTest.java | 13 +-
.../runtime/standalone/StandaloneHerderTest.java | 37 +-
.../storage/FileOffsetBackingStoreTest.java | 3 +-
.../storage/KafkaStatusBackingStoreFormatTest.java | 7 +-
.../storage/KafkaStatusBackingStoreTest.java | 9 +-
.../connect/storage/OffsetStorageWriterTest.java | 5 +-
.../kafka/connect/util/ConnectUtilsTest.java | 7 +-
.../connect/util/ConvertingFutureCallbackTest.java | 20 +-
.../kafka/connect/util/LoggingContextTest.java | 15 +-
.../util/clusters/EmbeddedKafkaCluster.java | 16 +-
.../apache/kafka/connect/transforms/CastTest.java | 32 +-
.../kafka/connect/transforms/FlattenTest.java | 22 +-
.../kafka/connect/transforms/InsertFieldTest.java | 17 +-
.../connect/transforms/SetSchemaMetadataTest.java | 3 +-
.../connect/transforms/TimestampConverterTest.java | 19 +-
.../transforms/util/NonEmptyListValidatorTest.java | 12 +-
.../kafka/admin/ReassignPartitionsCommand.scala | 83 +-
core/src/main/scala/kafka/log/Log.scala | 105 ++-
core/src/main/scala/kafka/log/LogManager.scala | 30 +-
.../scala/kafka/log/ProducerStateManager.scala | 15 +-
core/src/main/scala/kafka/log/TimeIndex.scala | 6 +-
.../main/scala/kafka/network/RequestChannel.scala | 18 +-
.../main/scala/kafka/network/SocketServer.scala | 113 +--
.../main/scala/kafka/raft/KafkaMetadataLog.scala | 2 +-
.../scala/kafka/raft/KafkaNetworkChannel.scala | 1 +
core/src/main/scala/kafka/raft/RaftManager.scala | 268 ++++++
.../kafka/security/authorizer/AclAuthorizer.scala | 1 +
.../src/main/scala/kafka/server/AdminManager.scala | 22 +-
.../main/scala/kafka/server/AlterIsrManager.scala | 61 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 295 ++++---
core/src/main/scala/kafka/server/KafkaConfig.scala | 14 +-
.../main/scala/kafka/server/MetadataCache.scala | 14 +-
.../scala/kafka/tools/TestRaftRequestHandler.scala | 15 +-
.../main/scala/kafka/tools/TestRaftServer.scala | 244 +-----
.../AdminClientWithPoliciesIntegrationTest.scala | 15 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 126 ++-
.../kafka/api/BaseProducerSendTest.scala | 5 +-
.../integration/kafka/api/BaseQuotaTest.scala | 3 +-
.../kafka/api/EndToEndAuthorizationTest.scala | 31 +-
.../kafka/api/GroupAuthorizerIntegrationTest.scala | 11 +-
.../scala/integration/kafka/api/MetricsTest.scala | 3 +-
.../kafka/api/PlaintextAdminIntegrationTest.scala | 59 +-
.../kafka/api/PlaintextConsumerTest.scala | 23 +-
.../api/PlaintextEndToEndAuthorizationTest.scala | 3 +-
.../kafka/api/PlaintextProducerSendTest.scala | 21 +-
.../kafka/api/ProducerFailureHandlingTest.scala | 34 +-
.../kafka/api/SaslEndToEndAuthorizationTest.scala | 3 +-
.../integration/kafka/api/TransactionsTest.scala | 42 +-
.../kafka/network/DynamicConnectionQuotaTest.scala | 5 +-
.../server/DynamicBrokerReconfigurationTest.scala | 7 +-
.../kafka/tools/MirrorMakerIntegrationTest.scala | 4 +-
.../scala/kafka/security/auth/ResourceTest.scala | 8 +-
core/src/test/scala/kafka/utils/ExitTest.scala | 11 +-
.../test/scala/kafka/zk/ExtendedAclStoreTest.scala | 10 +-
.../test/scala/kafka/zk/LiteralAclStoreTest.scala | 7 +-
.../test/scala/unit/kafka/KafkaConfigTest.scala | 12 +-
.../scala/unit/kafka/admin/AclCommandTest.scala | 9 +-
.../unit/kafka/admin/AdminRackAwareTest.scala | 11 +-
.../scala/unit/kafka/admin/ConfigCommandTest.scala | 87 +-
.../kafka/admin/DelegationTokenCommandTest.scala | 3 +-
.../kafka/admin/DeleteConsumerGroupsTest.scala | 8 +-
.../scala/unit/kafka/admin/DeleteTopicTest.scala | 3 +-
.../kafka/admin/DescribeConsumerGroupTest.scala | 5 +-
.../unit/kafka/admin/FeatureCommandTest.scala | 7 +-
.../unit/kafka/admin/ListConsumerGroupTest.scala | 21 +-
.../kafka/admin/ReassignPartitionsUnitTest.scala | 205 ++---
.../kafka/admin/ResetConsumerGroupOffsetTest.scala | 4 +-
.../scala/unit/kafka/admin/TopicCommandTest.scala | 13 +-
.../admin/TopicCommandWithAdminClientTest.scala | 82 +-
.../kafka/admin/TopicCommandWithZKClientTest.scala | 65 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 35 +-
.../scala/unit/kafka/cluster/ReplicaTest.scala | 4 +-
.../controller/ControllerChannelManagerTest.scala | 3 +-
.../kafka/controller/ControllerFailoverTest.scala | 3 +-
.../controller/ControllerIntegrationTest.scala | 19 +-
.../coordinator/group/GroupCoordinatorTest.scala | 30 +-
.../group/GroupMetadataManagerTest.scala | 35 +-
.../coordinator/group/GroupMetadataTest.scala | 45 +-
.../coordinator/group/MemberMetadataTest.scala | 10 +-
.../transaction/ProducerIdManagerTest.scala | 4 +-
.../transaction/TransactionLogTest.scala | 7 +-
.../transaction/TransactionMetadataTest.scala | 24 +-
.../transaction/TransactionStateManagerTest.scala | 17 +-
.../MetricsDuringTopicCreationDeletionTest.scala | 8 +-
.../integration/UncleanLeaderElectionTest.scala | 6 +-
.../unit/kafka/log/LogCleanerManagerTest.scala | 13 +-
.../test/scala/unit/kafka/log/LogCleanerTest.scala | 21 +-
.../test/scala/unit/kafka/log/LogConfigTest.scala | 15 +-
.../test/scala/unit/kafka/log/LogManagerTest.scala | 41 +-
core/src/test/scala/unit/kafka/log/LogTest.scala | 168 ++--
.../scala/unit/kafka/log/LogValidatorTest.scala | 105 ++-
.../scala/unit/kafka/log/OffsetIndexTest.scala | 11 +-
.../unit/kafka/log/ProducerStateManagerTest.scala | 57 +-
.../test/scala/unit/kafka/log/TimeIndexTest.scala | 21 +-
.../unit/kafka/log/TransactionIndexTest.scala | 21 +-
.../unit/kafka/network/ConnectionQuotasTest.scala | 57 +-
.../unit/kafka/network/SocketServerTest.scala | 5 +-
.../unit/kafka/raft/KafkaNetworkChannelTest.scala | 61 +-
.../scala/unit/kafka/raft/RaftManagerTest.scala | 68 ++
.../kafka/security/auth/PermissionTypeTest.scala | 3 +-
.../kafka/security/auth/ResourceTypeTest.scala | 3 +-
.../security/auth/SimpleAclAuthorizerTest.scala | 12 +-
.../security/authorizer/AclAuthorizerTest.scala | 16 +-
.../kafka/server/AbstractFetcherThreadTest.scala | 5 +-
.../unit/kafka/server/AlterIsrManagerTest.scala | 168 ++--
.../kafka/server/ClientQuotasRequestTest.scala | 37 +-
.../unit/kafka/server/DelayedOperationTest.scala | 3 +-
.../DelegationTokenRequestsOnPlainTextTest.scala | 10 +-
.../kafka/server/DelegationTokenRequestsTest.scala | 8 +-
...nTokenRequestsWithDisableTokenFeatureTest.scala | 16 +-
.../kafka/server/DynamicBrokerConfigTest.scala | 11 +-
.../kafka/server/DynamicConfigChangeTest.scala | 5 +-
.../unit/kafka/server/DynamicConfigTest.scala | 38 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 92 +--
.../scala/unit/kafka/server/KafkaConfigTest.scala | 49 +-
.../scala/unit/kafka/server/KafkaServerTest.scala | 12 +-
.../unit/kafka/server/LogDirFailureTest.scala | 3 +-
.../unit/kafka/server/MetadataCacheTest.scala | 66 +-
.../unit/kafka/server/MetadataRequestTest.scala | 6 +-
.../unit/kafka/server/ProduceRequestTest.scala | 3 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 6 +-
.../kafka/server/ServerGenerateBrokerIdTest.scala | 5 +-
.../kafka/server/ServerGenerateClusterIdTest.scala | 9 +-
.../unit/kafka/server/ServerMetricsTest.scala | 5 +-
.../unit/kafka/server/UpdateFeaturesTest.scala | 7 +-
.../checkpoints/OffsetCheckpointFileTest.scala | 10 +-
.../unit/kafka/tools/ConsoleConsumerTest.scala | 38 +-
.../unit/kafka/tools/ConsoleProducerTest.scala | 21 +-
.../unit/kafka/tools/ConsumerPerformanceTest.scala | 12 +-
.../unit/kafka/tools/DumpLogSegmentsTest.scala | 3 +-
.../unit/kafka/utils/CommandLineUtilsTest.scala | 8 +-
.../scala/unit/kafka/utils/QuotaUtilsTest.scala | 11 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 9 +-
.../scala/unit/kafka/zk/AdminZkClientTest.scala | 46 +-
.../scala/unit/kafka/zk/KafkaZkClientTest.scala | 64 +-
.../kafka/zk/ReassignPartitionsZNodeTest.scala | 3 +-
.../unit/kafka/zookeeper/ZooKeeperClientTest.scala | 20 +-
docs/streams/developer-guide/config-streams.html | 3 +-
.../java/org/apache/kafka/message/FieldSpec.java | 19 +
.../java/org/apache/kafka/message/FieldType.java | 22 +
.../kafka/message/JsonConverterGenerator.java | 10 +-
.../apache/kafka/message/MessageDataGenerator.java | 20 +
.../org/apache/kafka/message/MessageGenerator.java | 53 +-
.../org/apache/kafka/message/MessageSpecType.java | 18 +
.../message/MetadataJsonConvertersGenerator.java | 123 +++
.../kafka/message/MetadataRecordTypeGenerator.java | 180 +++++
.../org/apache/kafka/message/SchemaGenerator.java | 6 +
gradle/dependencies.gradle | 2 +-
.../log4jappender/KafkaLog4jAppenderTest.java | 87 +-
.../org/apache/kafka/metadata/BrokerState.java | 110 +++
.../kafka/metadata/MetadataParseException.java | 10 +-
.../org/apache/kafka/metadata/MetadataParser.java | 115 +++
.../org/apache/kafka/metadata/VersionRange.java | 57 +-
.../common/metadata/AccessControlRecord.json | 37 +
.../resources/common/metadata/ConfigRecord.json | 20 +-
.../common/metadata/DelegationTokenRecord.json | 29 +-
.../common/metadata/FeatureLevelRecord.json | 19 +-
.../common/metadata/FenceBrokerRecord.json | 10 +-
.../resources/common/metadata/IsrChangeRecord.json | 28 +-
.../resources/common/metadata/PartitionRecord.json | 39 +
.../resources/common/metadata/QuotaRecord.json | 29 +-
.../common/metadata/RegisterBrokerRecord.json | 51 ++
.../common/metadata/RemoveTopicRecord.json | 8 +-
.../resources/common/metadata/TopicRecord.json | 10 +-
.../common/metadata/UnfenceBrokerRecord.json | 10 +-
.../common/metadata/UnregisterBrokerRecord.json | 10 +-
.../common/metadata/UserScramCredentialRecord.json | 29 +-
.../org/apache/kafka/metadata/BrokerStateTest.java | 24 +-
.../apache/kafka/metadata/MetadataParserTest.java | 155 ++++
.../apache/kafka/metadata/VersionRangeTest.java | 61 ++
.../src/test/resources/log4j.properties | 6 +-
.../org/apache/kafka/raft/KafkaRaftClient.java | 107 ++-
.../java/org/apache/kafka/raft/RaftClient.java | 18 +-
.../java/org/apache/kafka/raft/RaftConfig.java | 43 +-
.../org/apache/kafka/snapshot/SnapshotWriter.java | 2 +-
.../org/apache/kafka/raft/KafkaRaftClientTest.java | 5 +-
.../apache/kafka/raft/RaftClientTestContext.java | 36 +-
.../java/org/apache/kafka/raft/RaftConfigTest.java | 1 -
.../apache/kafka/raft/RaftEventSimulationTest.java | 76 +-
.../java/org/apache/kafka/raft/RaftTestUtil.java | 65 ++
settings.gradle | 1 +
.../examples/docs/DeveloperGuideTesting.java | 10 +-
.../examples/wordcount/WordCountDemoTest.java | 10 +-
.../examples/wordcount/WordCountProcessorTest.java | 4 +-
.../wordcount/WordCountTransformerTest.java | 8 +-
.../org/apache/kafka/streams/KafkaStreams.java | 80 +-
.../org/apache/kafka/streams/StreamsConfig.java | 3 +-
.../errors/DeserializationExceptionHandler.java | 6 +
.../streams/processor/internals/AbstractTask.java | 7 +-
.../processor/internals/ActiveTaskCreator.java | 10 +-
.../processor/internals/GlobalStreamThread.java | 4 +
.../streams/processor/internals/StandbyTask.java | 4 +-
.../processor/internals/StandbyTaskCreator.java | 10 +-
.../streams/processor/internals/StreamTask.java | 17 +-
.../streams/processor/internals/StreamThread.java | 39 +-
.../internals/StreamsRebalanceListener.java | 1 +
.../kafka/streams/processor/internals/Task.java | 162 ++--
.../streams/processor/internals/TaskManager.java | 4 +-
.../kafka/streams/state/internals/ThreadCache.java | 5 +-
.../org/apache/kafka/streams/KafkaStreamsTest.java | 59 +-
.../apache/kafka/streams/StreamsBuilderTest.java | 8 +-
.../apache/kafka/streams/StreamsConfigTest.java | 36 +-
.../org/apache/kafka/streams/TopologyTest.java | 84 +-
.../integration/AdjustStreamThreadCountTest.java | 130 ++-
.../integration/StoreQueryIntegrationTest.java | 7 +-
.../kafka/streams/kstream/JoinWindowsTest.java | 5 +-
.../apache/kafka/streams/kstream/NamedTest.java | 5 +-
.../apache/kafka/streams/kstream/PrintedTest.java | 21 +-
.../kafka/streams/kstream/TimeWindowsTest.java | 9 +-
.../streams/kstream/UnlimitedWindowsTest.java | 5 +-
.../apache/kafka/streams/kstream/WindowTest.java | 9 +-
.../apache/kafka/streams/kstream/WindowsTest.java | 9 +-
.../kstream/internals/KGroupedTableImplTest.java | 90 +--
.../streams/kstream/internals/KTableImplTest.java | 81 +-
.../kstream/internals/SessionWindowTest.java | 5 +-
.../SessionWindowedCogroupedKStreamImplTest.java | 48 +-
.../internals/SessionWindowedKStreamImplTest.java | 57 +-
.../streams/kstream/internals/TimeWindowTest.java | 9 +-
.../TimeWindowedCogroupedKStreamImplTest.java | 36 +-
.../internals/TimeWindowedKStreamImplTest.java | 53 +-
.../kstream/internals/UnlimitedWindowTest.java | 5 +-
.../foreignkeyjoin/CombinedKeySchemaTest.java | 13 +-
.../SubscriptionResponseWrapperSerdeTest.java | 6 +-
.../SubscriptionWrapperSerdeTest.java | 14 +-
.../processor/DefaultPartitionGrouperTest.java | 5 +-
.../processor/FailOnInvalidTimestampTest.java | 6 +-
.../internals/AbstractProcessorContextTest.java | 5 +-
.../internals/CopartitionedTopicsEnforcerTest.java | 13 +-
.../ForwardingDisabledProcessorContextTest.java | 18 +-
.../internals/GlobalProcessorContextImplTest.java | 21 +-
.../internals/GlobalStateManagerImplTest.java | 17 +-
.../internals/InternalTopicConfigTest.java | 13 +-
.../internals/InternalTopologyBuilderTest.java | 97 +--
.../processor/internals/ProcessorNodeTest.java | 9 +-
.../internals/StateRestoreCallbackAdapterTest.java | 9 +-
.../internals/StoreChangelogReaderTest.java | 4 +-
.../processor/internals/StreamTaskTest.java | 258 ++++--
.../internals/StreamsMetadataStateTest.java | 21 +-
.../internals/StreamsRebalanceListenerTest.java | 6 +-
.../processor/internals/TaskManagerTest.java | 2 +-
.../internals/assignment/AssignmentInfoTest.java | 11 +-
.../internals/assignment/SubscriptionInfoTest.java | 13 +-
.../internals/metrics/StreamsMetricsImplTest.java | 8 +-
.../streams/state/KeyValueStoreTestDriver.java | 2 +-
.../kafka/streams/state/StateSerdesTest.java | 32 +-
.../internals/AbstractSessionBytesStoreTest.java | 33 +-
.../CompositeReadOnlySessionStoreTest.java | 21 +-
.../state/internals/FilteredCacheIteratorTest.java | 5 +-
.../internals/GlobalStateStoreProviderTest.java | 6 +-
.../state/internals/KeyValueStoreBuilderTest.java | 17 +-
.../state/internals/MeteredSessionStoreTest.java | 32 +-
.../streams/state/internals/NamedCacheTest.java | 6 +-
.../internals/QueryableStoreProviderTest.java | 20 +-
.../StreamThreadStateStoreProviderTest.java | 30 +-
.../state/internals/WindowStoreBuilderTest.java | 18 +-
.../state/internals/WrappingStoreProviderTest.java | 5 +-
.../kafka/streams/tests/SystemTestUtilTest.java | 13 +-
.../kafka/streams/MockProcessorContextTest.java | 12 +-
.../org/apache/kafka/streams/MockTimeTest.java | 10 +-
.../org/apache/kafka/streams/TestTopicsTest.java | 57 +-
.../streams/TopologyTestDriverAtLeastOnceTest.java | 13 +-
.../kafka/streams/TopologyTestDriverEosTest.java | 14 +-
.../kafka/streams/TopologyTestDriverTest.java | 77 +-
.../streams/internals/KeyValueStoreFacadeTest.java | 19 +-
.../streams/internals/WindowStoreFacadeTest.java | 14 +-
.../streams/test/ConsumerRecordFactoryTest.java | 60 +-
.../streams/test/MockProcessorContextAPITest.java | 2 +-
.../test/MockProcessorContextStateStoreTest.java | 47 +-
.../kafka/streams/test/OutputVerifierTest.java | 419 ++++------
.../apache/kafka/streams/test/TestRecordTest.java | 12 +-
.../wordcount/WindowedWordCountProcessorTest.java | 2 +-
tests/docker/Dockerfile | 6 +-
.../client/client_compatibility_features_test.py | 4 +-
.../client_compatibility_produce_consume_test.py | 4 +-
.../core/compatibility_test_new_broker_test.py | 4 +-
tests/kafkatest/tests/core/upgrade_test.py | 12 +-
.../tests/streams/streams_optimized_test.py | 55 +-
tests/kafkatest/version.py | 3 +-
vagrant/base.sh | 4 +-
608 files changed, 10826 insertions(+), 9061 deletions(-)
copy
clients/src/{main/java/org/apache/kafka/clients/consumer/internals/RequestFutureListener.java
=>
test/java/org/apache/kafka/clients/consumer/internals/CooperativeConsumerCoordinatorTest.java}
(75%)
copy
clients/src/{main/java/org/apache/kafka/clients/consumer/internals/NoAvailableBrokersException.java
=>
test/java/org/apache/kafka/clients/consumer/internals/EagerConsumerCoordinatorTest.java}
(76%)
copy
clients/src/{main/java/org/apache/kafka/common/security/authenticator/DefaultLogin.java
=>
test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorFailureNoDelayTest.java}
(83%)
copy
clients/src/{main/java/org/apache/kafka/common/security/authenticator/DefaultLogin.java
=>
test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorFailurePositiveDelayTest.java}
(83%)
copy clients/src/test/java/org/apache/kafka/common/{utils/SystemTimeTest.java
=> security/ssl/Tls12SslFactoryTest.java} (83%)
copy
clients/src/{main/java/org/apache/kafka/common/errors/DuplicateSequenceException.java
=> test/java/org/apache/kafka/common/security/ssl/Tls13SslFactoryTest.java}
(73%)
create mode 100644
connect/basic-auth-extension/src/test/java/org/apache/kafka/connect/rest/basic/auth/extension/BasicAuthSecurityRestExtensionTest.java
delete mode 100644
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
create mode 100644
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java
create mode 100644
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationSSLTest.java
copy
clients/src/main/java/org/apache/kafka/common/errors/InvalidRequiredAcksException.java
=>
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationTest.java
(74%)
create mode 100644 core/src/main/scala/kafka/raft/RaftManager.scala
create mode 100644 core/src/test/scala/unit/kafka/raft/RaftManagerTest.scala
create mode 100644
generator/src/main/java/org/apache/kafka/message/MetadataJsonConvertersGenerator.java
create mode 100644
generator/src/main/java/org/apache/kafka/message/MetadataRecordTypeGenerator.java
create mode 100644
metadata/src/main/java/org/apache/kafka/metadata/BrokerState.java
copy
clients/src/main/java/org/apache/kafka/common/errors/InvalidRequiredAcksException.java
=>
metadata/src/main/java/org/apache/kafka/metadata/MetadataParseException.java
(79%)
create mode 100644
metadata/src/main/java/org/apache/kafka/metadata/MetadataParser.java
copy
clients/src/main/java/org/apache/kafka/common/network/CipherInformation.java =>
metadata/src/main/java/org/apache/kafka/metadata/VersionRange.java (50%)
create mode 100644
metadata/src/main/resources/common/metadata/AccessControlRecord.json
copy
clients/src/main/resources/common/message/DescribeUserScramCredentialsRequest.json
=> metadata/src/main/resources/common/metadata/ConfigRecord.json (59%)
copy clients/src/main/resources/common/message/LeaderChangeMessage.json =>
metadata/src/main/resources/common/metadata/DelegationTokenRecord.json (50%)
copy clients/src/main/resources/common/message/EnvelopeResponse.json =>
metadata/src/main/resources/common/metadata/FeatureLevelRecord.json (62%)
copy core/src/main/resources/common/message/TransactionLogKey.json =>
metadata/src/main/resources/common/metadata/FenceBrokerRecord.json (73%)
copy clients/src/main/resources/common/message/DescribeQuorumRequest.json =>
metadata/src/main/resources/common/metadata/IsrChangeRecord.json (54%)
create mode 100644
metadata/src/main/resources/common/metadata/PartitionRecord.json
copy clients/src/main/resources/common/message/FindCoordinatorRequest.json =>
metadata/src/main/resources/common/metadata/QuotaRecord.json (51%)
create mode 100644
metadata/src/main/resources/common/metadata/RegisterBrokerRecord.json
copy core/src/main/resources/common/message/TransactionLogKey.json =>
metadata/src/main/resources/common/metadata/RemoveTopicRecord.json (79%)
copy core/src/main/resources/common/message/TransactionLogKey.json =>
metadata/src/main/resources/common/metadata/TopicRecord.json (76%)
copy core/src/main/resources/common/message/TransactionLogKey.json =>
metadata/src/main/resources/common/metadata/UnfenceBrokerRecord.json (74%)
copy core/src/main/resources/common/message/TransactionLogKey.json =>
metadata/src/main/resources/common/metadata/UnregisterBrokerRecord.json (75%)
copy
clients/src/main/resources/common/message/AlterUserScramCredentialsRequest.json
=> metadata/src/main/resources/common/metadata/UserScramCredentialRecord.json
(59%)
copy
clients/src/test/java/org/apache/kafka/clients/admin/ScramMechanismTest.java =>
metadata/src/test/java/org/apache/kafka/metadata/BrokerStateTest.java (59%)
create mode 100644
metadata/src/test/java/org/apache/kafka/metadata/MetadataParserTest.java
create mode 100644
metadata/src/test/java/org/apache/kafka/metadata/VersionRangeTest.java
copy {tools => metadata}/src/test/resources/log4j.properties (90%)
create mode 100644 raft/src/test/java/org/apache/kafka/raft/RaftTestUtil.java
copy
clients/src/main/java/org/apache/kafka/common/errors/TopicDeletionDisabledException.java
=>
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverAtLeastOnceTest.java
(73%)
copy
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultLogin.java
=>
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverEosTest.java
(74%)
