This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch kafka-10867-improved-task-idling
in repository https://gitbox.apache.org/repos/asf/kafka.git.
discard a366fc3 Rollback streams-side metadata caching
discard 9a443e9 Streams changes to cope with cached metadata response
discard 738fd9d ditto
discard 0e6d41f disable idling for selected ITs
discard 375bb08 fix diff
discard 90294e3 switch default
discard 339cfe9 KAFKA-10867: Improved task idling
discard ddef3d1 Rollback consumer-side metadata caching
discard 86e267b Consumer changes to cope with cached metadata response
discard 7d7f19f spotbugs
discard 667ec8e fix test
discard 0cd4af0 fix core integration test failures
discard dc27e3f tests
discard 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 0c92b83 KAFKA-12203 Migrate connect:mirror-client module to JUnit 5
(#9889)
add 63f49f9 KAFKA-12189 ShellTest can replace 'assumeTrue' by (junit 5)
conditional test (#9898)
add 738904e KAFKA-12191 SslTransportTls12Tls13Test can replace
'assumeTrue' by (junit 5) conditional test (#9899)
add 144b123 MINOR: Remove incorrect code in metadata module build (#9897)
add c9f3d5e KAFKA-12206: o.a.k.common.Uuid should implement Comparable
(#9896)
add 9361a43 MINOR: remove unused flag 'hasIdempotentRecords' (#9884)
add 3e6c6f5 KAFKA-12198: Migrate connect:json module to JUnit 5 (#9890)
add ba1e16f MINOR: Upstream ApisUtils from kip-500 (#9715)
add b5c1073 KAFKA-12208: Rename AdminManager to ZkAdminManager (#9900)
add 7ac0606 KAFKA-12161; Support raft observers with optional id (#9871)
add 06c9a39 KAFKA-12214: Generated code does not include UUID or struct
fields in its toString output (#9914)
add 8f063c1 MINOR: Generalize server startup to make way for KIP-500
(#9883)
add bfc96ef KAFKA-10674: Controller API version bond with forwardable
APIs (#9600)
add 6f9e73c MINOR: Move a few more methods to AuthHelper (#9913)
add 4126cfd KAFKA-12197: Migrate connect:transforms module to JUnit 5
(#9907)
add e0ebb1d KAFKA-12202 Migrate connect:mirror module to JUnit 5 (#9894)
add 87df3b9 MINOR: Delete unused `jenkins.sh` (#9919)
add 962b69b KAFKA-12200: Migrate connect:file module to JUnit 5 (#9917)
add 462be6d KAFKA-12196: Migrate connect:api module to JUnit 5 (#9909)
add 7bd10ff MINOR: Make data in FetchSnapshotRequest and
FetchSnapshotRespponse private (#9820)
add 5a4bbb9 KAFKA-7341 Migrate core module to JUnit 5 (#9855)
add f2ac0c6 KAFKA-12221 remove PowerMock from connect-json module and
connect-transforms module (#9924)
add 8648643 MINOR: Use Gradle's JUnitPlatform for upgrade-system-tests
modules (#9922)
add 1ca497a MINOR: Upgrade gradle to 6.8 and test retry plugin to 1.2.0
(#9849)
add efff9db KAFKA-10841: Extract conversion from LogReadResult to
FetchPartitionData (#9743)
add 277c437 KAFKA-12194: use stateListener to catch each state change
(#9888)
add 6752f28 KAFKA-12195 Fix synchronization issue happening in
KafkaStreams (#9887)
add 418aaa0 MINOR: Ensure compile and runtime classpaths have consistent
versions (#9921)
add ef5b7b7 MINOR: Exclude junit 3 transitive dependency from jfreechart
(#9928)
add f7c0b0d MINOR: Replace ApiVersion by auto-generated protocol (#9746)
add 302eee6 KAFKA-12204; Implement DescribeCluster API in the broker
(KIP-700) (#9903)
add 130274b KAFKA-10017: fix uncaucht-exception handling in
EosBetaUpgradeIntegrationTest (#9733)
add 4c6f900 KAFKA-12219: Add 'synchronized' keyword to
InMemoryKeyValueStore#[reverseRange, reverseAll] (#9923)
add be88f5a MINOR: Fix StreamsOptimizedTest (#9911)
add add160d KAFKA-9924: Add docs for RocksDB properties-based metrics
(#9895)
add 0158e1d MINOR: Add 'task container' class to KafkaStreams TaskManager
(#9835)
add 918c332 KAFKA-8460: produce records with current timestamp (#9877)
add 38b320a HOTFIX: fix RocksDBMetricsTest (#9935)
add 8c7e551 KAFKA-10866: Add fetched metadata to ConsumerRecords
add d091e9c tests
add 06b2492 fix core integration test failures
add 118ecfb fix test
add 36db117 spotbugs
add 3da66f1 Consumer changes to cope with cached metadata response
add 3b4e86c Rollback consumer-side metadata caching
add 2e46bce drop beginningOffset from the metadata
add a8df8df KAFKA-10867: Improved task idling
add a858ed3 switch default
add 841ce32 fix diff
add f8b4806 disable idling for selected ITs
add 10043ef ditto
add 8969533 Streams changes to cope with cached metadata response
add 092ef77 Rollback streams-side metadata caching
add a48dd7f rebase fix
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 (a366fc3)
\
N -- N -- N refs/heads/kafka-10867-improved-task-idling (a48dd7f)
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 | 140 ++-
checkstyle/import-control.xml | 19 +
checkstyle/suppressions.xml | 5 +-
.../java/org/apache/kafka/clients/ApiVersion.java | 56 --
.../org/apache/kafka/clients/NetworkClient.java | 6 +-
.../org/apache/kafka/clients/NodeApiVersions.java | 82 +-
.../java/org/apache/kafka/clients/admin/Admin.java | 9 +-
.../kafka/clients/consumer/ConsumerConfig.java | 23 +-
.../kafka/clients/consumer/ConsumerRecords.java | 12 -
.../kafka/clients/consumer/MockConsumer.java | 3 +-
.../consumer/internals/AbstractCoordinator.java | 4 +
.../kafka/clients/consumer/internals/Fetcher.java | 4 +-
.../producer/internals/TransactionManager.java | 4 +-
.../internals/TransactionalRequestResult.java | 2 +-
.../main/java/org/apache/kafka/common/Cluster.java | 4 +-
.../main/java/org/apache/kafka/common/Uuid.java | 17 +-
.../org/apache/kafka/common/config/ConfigDef.java | 16 +-
.../errors/PrincipalDeserializationException.java | 5 +
.../kafka/common/metrics/stats/TokenBucket.java | 2 +-
.../org/apache/kafka/common/protocol/ApiKeys.java | 3 +-
.../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 +
.../kafka/common/requests/AbstractRequest.java | 2 +
.../kafka/common/requests/AbstractResponse.java | 2 +
.../kafka/common/requests/ApiVersionsRequest.java | 10 +-
.../kafka/common/requests/ApiVersionsResponse.java | 75 +-
.../common/requests/DescribeClusterRequest.java | 76 ++
.../common/requests/DescribeClusterResponse.java | 63 ++
.../apache/kafka/common/requests/FetchRequest.java | 25 -
.../kafka/common/requests/FetchResponse.java | 39 +-
.../common/requests/FetchSnapshotRequest.java | 14 +-
.../common/requests/FetchSnapshotResponse.java | 17 +-
.../apache/kafka/common/requests/RequestUtils.java | 42 +-
.../authenticator/SaslClientAuthenticator.java | 6 +-
.../java/org/apache/kafka/common/utils/Utils.java | 18 +-
.../common/message/ApiVersionsResponse.json | 2 +-
...eteRequest.json => DescribeClusterRequest.json} | 21 +-
.../common/message/DescribeClusterResponse.json | 47 +
.../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 | 111 ++-
.../apache/kafka/clients/NodeApiVersionsTest.java | 64 +-
.../org/apache/kafka/clients/admin/ConfigTest.java | 61 +-
.../DeleteConsumerGroupOffsetsResultTest.java | 12 +-
.../DescribeUserScramCredentialsResultTest.java | 12 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 223 +++--
.../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 | 160 ++--
.../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} | 13 +-
.../internals/EagerConsumerCoordinatorTest.java} | 14 +-
.../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 | 57 +-
.../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 | 173 ++--
.../internals/StickyPartitionCacheTest.java | 6 +-
.../producer/internals/TransactionManagerTest.java | 131 +--
.../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 | 22 +-
.../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 | 75 +-
.../kafka/common/message/RecordsSerdeTest.java | 6 +-
.../common/message/SimpleExampleMessageTest.java | 56 +-
.../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 | 24 +-
.../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 | 118 ++-
.../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 | 20 +-
.../kafka/common/requests/ProduceResponseTest.java | 20 +-
.../kafka/common/requests/RequestContextTest.java | 12 +-
.../kafka/common/requests/RequestHeaderTest.java | 4 +-
.../kafka/common/requests/RequestResponseTest.java | 117 ++-
.../kafka/common/requests/RequestTestUtils.java | 4 +
.../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 | 103 +--
.../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} | 13 +-
.../ssl/Tls13SslFactoryTest.java} | 15 +-
.../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 | 46 +-
.../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 | 10 +-
.../kafka/connect/connector/ConnectorTest.java | 6 +-
.../kafka/connect/data/ConnectSchemaTest.java | 123 +--
.../org/apache/kafka/connect/data/DateTest.java | 20 +-
.../org/apache/kafka/connect/data/DecimalTest.java | 6 +-
.../org/apache/kafka/connect/data/FieldTest.java | 6 +-
.../kafka/connect/data/SchemaBuilderTest.java | 110 ++-
.../kafka/connect/data/SchemaProjectorTest.java | 149 ++--
.../org/apache/kafka/connect/data/StructTest.java | 40 +-
.../org/apache/kafka/connect/data/TimeTest.java | 20 +-
.../apache/kafka/connect/data/TimestampTest.java | 15 +-
.../org/apache/kafka/connect/data/ValuesTest.java | 50 +-
.../kafka/connect/header/ConnectHeaderTest.java | 14 +-
.../kafka/connect/header/ConnectHeadersTest.java | 29 +-
.../kafka/connect/sink/SinkConnectorTest.java | 6 +-
.../apache/kafka/connect/sink/SinkRecordTest.java | 20 +-
.../kafka/connect/source/SourceConnectorTest.java | 6 +-
.../kafka/connect/source/SourceRecordTest.java | 20 +-
.../kafka/connect/storage/ConverterTypeTest.java | 4 +-
.../connect/storage/SimpleHeaderConverterTest.java | 14 +-
.../kafka/connect/storage/StringConverterTest.java | 13 +-
.../kafka/connect/util/ConnectorUtilsTest.java | 10 +-
.../extension/BasicAuthSecurityRestExtension.java | 7 +-
.../basic/auth/extension/JaasBasicAuthFilter.java | 16 +-
.../BasicAuthSecurityRestExtensionTest.java | 66 ++
.../auth/extension/JaasBasicAuthFilterTest.java | 179 ++--
.../connect/file/FileStreamSinkConnectorTest.java | 14 +-
.../kafka/connect/file/FileStreamSinkTaskTest.java | 22 +-
.../file/FileStreamSourceConnectorTest.java | 31 +-
.../connect/file/FileStreamSourceTaskTest.java | 21 +-
.../apache/kafka/connect/json/JsonConverter.java | 10 +
.../connect/json/JsonConverterConfigTest.java | 9 +-
.../kafka/connect/json/JsonConverterTest.java | 72 +-
.../kafka/connect/mirror/MirrorClientTest.java | 8 +-
.../kafka/connect/mirror/MirrorMakerConfig.java | 4 +-
.../kafka/connect/mirror/CheckpointTest.java | 4 +-
.../apache/kafka/connect/mirror/HeartbeatTest.java | 4 +-
.../mirror/MirrorCheckpointConnectorTest.java | 4 +-
.../connect/mirror/MirrorCheckpointTaskTest.java | 4 +-
.../connect/mirror/MirrorConnectorConfigTest.java | 16 +-
.../mirror/MirrorConnectorsIntegrationTest.java | 595 -------------
.../mirror/MirrorHeartBeatConnectorTest.java | 4 +-
.../connect/mirror/MirrorMakerConfigTest.java | 165 ++--
.../connect/mirror/MirrorSourceConnectorTest.java | 55 +-
.../kafka/connect/mirror/MirrorSourceTaskTest.java | 38 +-
.../kafka/connect/mirror/OffsetSyncStoreTest.java | 4 +-
.../kafka/connect/mirror/OffsetSyncTest.java | 4 +-
.../org/apache/kafka/connect/mirror/TestUtils.java | 11 +
.../MirrorConnectorsIntegrationBaseTest.java | 600 +++++++++++++
.../MirrorConnectorsIntegrationSSLTest.java | 66 ++
.../MirrorConnectorsIntegrationTest.java | 13 +-
.../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/EmbeddedConnectCluster.java | 4 +-
.../util/clusters/EmbeddedKafkaCluster.java | 39 +-
.../apache/kafka/connect/transforms/CastTest.java | 44 +-
.../kafka/connect/transforms/ExtractFieldTest.java | 12 +-
.../kafka/connect/transforms/FlattenTest.java | 38 +-
.../kafka/connect/transforms/HoistFieldTest.java | 10 +-
.../kafka/connect/transforms/InsertFieldTest.java | 27 +-
.../kafka/connect/transforms/MaskFieldTest.java | 50 +-
.../kafka/connect/transforms/RegexRouterTest.java | 4 +-
.../kafka/connect/transforms/ReplaceFieldTest.java | 10 +-
.../connect/transforms/SetSchemaMetadataTest.java | 13 +-
.../connect/transforms/TimestampConverterTest.java | 29 +-
.../connect/transforms/TimestampRouterTest.java | 8 +-
.../kafka/connect/transforms/ValueToKeyTest.java | 12 +-
.../transforms/predicates/HasHeaderKeyTest.java | 24 +-
.../predicates/TopicNameMatchesTest.java | 20 +-
.../transforms/util/NonEmptyListValidatorTest.java | 13 +-
core/src/main/scala/kafka/Kafka.scala | 44 +-
.../kafka/admin/BrokerApiVersionsCommand.scala | 4 +-
.../kafka/admin/ReassignPartitionsCommand.scala | 83 +-
core/src/main/scala/kafka/api/ApiVersion.scala | 44 +-
core/src/main/scala/kafka/log/Log.scala | 105 ++-
core/src/main/scala/kafka/log/LogConfig.scala | 37 +-
core/src/main/scala/kafka/log/LogManager.scala | 32 +-
.../scala/kafka/log/ProducerStateManager.scala | 15 +-
core/src/main/scala/kafka/log/TimeIndex.scala | 6 +-
.../scala/kafka/metrics/KafkaMetricsReporter.scala | 4 +-
.../main/scala/kafka/network/RequestChannel.scala | 18 +-
.../scala/kafka/network/RequestConvertToJson.scala | 2 +
.../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 | 271 ++++++
.../kafka/security/authorizer/AclAuthorizer.scala | 1 +
.../main/scala/kafka/server/AlterIsrManager.scala | 61 +-
core/src/main/scala/kafka/server/AuthHelper.scala | 133 +++
.../src/main/scala/kafka/server/BrokerServer.scala | 19 +-
.../server/BrokerToControllerChannelManager.scala | 60 +-
.../main/scala/kafka/server/ControllerServer.scala | 19 +-
.../kafka/server/DelayedCreatePartitions.scala | 2 +-
.../scala/kafka/server/DelayedDeleteTopics.scala | 2 +-
.../src/main/scala/kafka/server/DelayedFetch.scala | 11 +-
.../scala/kafka/server/DynamicBrokerConfig.scala | 2 +-
.../scala/kafka/server/ForwardingManager.scala | 49 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 950 +++++++++------------
core/src/main/scala/kafka/server/KafkaConfig.scala | 35 +-
.../main/scala/kafka/server/KafkaRaftServer.scala | 103 +++
core/src/main/scala/kafka/server/KafkaServer.scala | 97 +--
.../scala/kafka/server/KafkaServerStartable.scala | 75 --
.../main/scala/kafka/server/MetadataCache.scala | 14 +-
.../main/scala/kafka/server/ReplicaManager.scala | 22 +-
.../scala/kafka/server/RequestHandlerHelper.scala | 195 +++++
core/src/main/scala/kafka/server/Server.scala | 73 ++
.../{AdminManager.scala => ZkAdminManager.scala} | 28 +-
.../scala/kafka/tools/TestRaftRequestHandler.scala | 15 +-
.../main/scala/kafka/tools/TestRaftServer.scala | 243 +-----
core/src/main/scala/kafka/utils/CoreUtils.scala | 3 +-
.../scala/kafka/utils/VerifiableProperties.scala | 8 +
.../kafka/admin/BrokerApiVersionsCommandTest.scala | 26 +-
.../admin/ReassignPartitionsIntegrationTest.scala | 39 +-
.../kafka/api/AbstractConsumerTest.scala | 16 +-
.../AdminClientWithPoliciesIntegrationTest.scala | 39 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 213 ++---
.../kafka/api/BaseAdminIntegrationTest.scala | 16 +-
.../integration/kafka/api/BaseConsumerTest.scala | 9 +-
.../kafka/api/BaseProducerSendTest.scala | 70 +-
.../integration/kafka/api/BaseQuotaTest.scala | 48 +-
.../integration/kafka/api/ClientIdQuotaTest.scala | 4 +-
.../integration/kafka/api/ConsumerBounceTest.scala | 38 +-
.../kafka/api/ConsumerTopicCreationTest.scala | 118 +--
.../kafka/api/CustomQuotaCallbackTest.scala | 12 +-
.../DelegationTokenEndToEndAuthorizationTest.scala | 7 +-
.../api/DescribeAuthorizedOperationsTest.scala | 8 +-
.../kafka/api/EndToEndAuthorizationTest.scala | 89 +-
.../kafka/api/EndToEndClusterIdTest.scala | 7 +-
.../kafka/api/GroupAuthorizerIntegrationTest.scala | 18 +-
.../api/GroupCoordinatorIntegrationTest.scala | 6 +-
.../kafka/api/IntegrationTestHarness.scala | 6 +-
.../integration/kafka/api/LogAppendTimeTest.scala | 7 +-
.../scala/integration/kafka/api/MetricsTest.scala | 41 +-
.../kafka/api/PlaintextAdminIntegrationTest.scala | 319 +++----
.../kafka/api/PlaintextConsumerTest.scala | 177 ++--
.../api/PlaintextEndToEndAuthorizationTest.scala | 9 +-
.../kafka/api/PlaintextProducerSendTest.scala | 29 +-
.../kafka/api/ProducerCompressionTest.scala | 47 +-
.../kafka/api/ProducerFailureHandlingTest.scala | 81 +-
.../kafka/api/RackAwareAutoTopicCreationTest.scala | 6 +-
.../SaslClientsWithInvalidCredentialsTest.scala | 29 +-
.../kafka/api/SaslEndToEndAuthorizationTest.scala | 10 +-
.../kafka/api/SaslMultiMechanismConsumerTest.scala | 30 +-
.../kafka/api/SaslPlainPlaintextConsumerTest.scala | 6 +-
.../SaslPlainSslEndToEndAuthorizationTest.scala | 2 +-
.../kafka/api/SaslPlaintextConsumerTest.scala | 6 +-
.../SaslScramSslEndToEndAuthorizationTest.scala | 4 +-
.../kafka/api/SaslSslAdminIntegrationTest.scala | 25 +-
.../kafka/api/SaslSslConsumerTest.scala | 6 +-
.../kafka/api/SslAdminIntegrationTest.scala | 20 +-
.../kafka/api/SslEndToEndAuthorizationTest.scala | 4 +-
.../kafka/api/TransactionsBounceTest.scala | 8 +-
.../kafka/api/TransactionsExpirationTest.scala | 6 +-
.../integration/kafka/api/TransactionsTest.scala | 72 +-
.../api/TransactionsWithMaxInFlightOneTest.scala | 8 +-
.../kafka/api/UserClientIdQuotaTest.scala | 4 +-
.../integration/kafka/api/UserQuotaTest.scala | 6 +-
.../kafka/network/DynamicConnectionQuotaTest.scala | 17 +-
.../kafka/server/DelayedFetchTest.scala | 4 +-
.../server/DynamicBrokerReconfigurationTest.scala | 123 ++-
.../kafka/server/GssapiAuthenticationTest.scala | 25 +-
...ListenersWithSameSecurityProtocolBaseTest.scala | 14 +-
.../kafka/server/ScramServerStartupTest.scala | 6 +-
.../kafka/tools/MirrorMakerIntegrationTest.scala | 18 +-
.../kafka/common/InterBrokerSendThreadTest.scala | 13 +-
.../metrics/LinuxIoMetricsCollectorTest.scala | 9 +-
.../scala/kafka/security/auth/ResourceTest.scala | 12 +-
.../scala/kafka/security/minikdc/MiniKdcTest.scala | 6 +-
.../server/BrokerMetadataCheckpointTest.scala | 4 +-
.../BrokerToControllerRequestThreadTest.scala | 18 +-
.../scala/kafka/tools/CustomDeserializerTest.scala | 9 +-
.../kafka/tools/DefaultMessageFormatterTest.scala | 61 +-
.../kafka/tools/ReplicaVerificationToolTest.scala | 8 +-
core/src/test/scala/kafka/utils/ExitTest.scala | 13 +-
core/src/test/scala/kafka/utils/LoggingTest.scala | 6 +-
.../test/scala/kafka/utils/ToolsUtilsTest.scala | 4 +-
.../test/scala/kafka/zk/ExtendedAclStoreTest.scala | 12 +-
.../src/test/scala/kafka/zk/FeatureZNodeTest.scala | 39 +-
.../test/scala/kafka/zk/LiteralAclStoreTest.scala | 9 +-
.../test/scala/unit/kafka/KafkaConfigTest.scala | 20 +-
.../scala/unit/kafka/admin/AclCommandTest.scala | 29 +-
.../scala/unit/kafka/admin/AddPartitionsTest.scala | 33 +-
.../unit/kafka/admin/AdminRackAwareTest.scala | 15 +-
.../scala/unit/kafka/admin/ConfigCommandTest.scala | 157 ++--
.../kafka/admin/ConsumerGroupCommandTest.scala | 6 +-
.../kafka/admin/DelegationTokenCommandTest.scala | 11 +-
.../kafka/admin/DeleteConsumerGroupsTest.scala | 56 +-
...ffsetsConsumerGroupCommandIntegrationTest.scala | 4 +-
.../scala/unit/kafka/admin/DeleteTopicTest.scala | 59 +-
.../kafka/admin/DescribeConsumerGroupTest.scala | 87 +-
.../unit/kafka/admin/FeatureCommandTest.scala | 9 +-
.../kafka/admin/LeaderElectionCommandTest.scala | 142 ++-
.../unit/kafka/admin/ListConsumerGroupTest.scala | 25 +-
...PreferredReplicaLeaderElectionCommandTest.scala | 27 +-
.../scala/unit/kafka/admin/RackAwareTest.scala | 15 +-
.../admin/ReassignPartitionsCommandArgsTest.scala | 21 +-
.../kafka/admin/ReassignPartitionsUnitTest.scala | 250 +++---
.../kafka/admin/ResetConsumerGroupOffsetTest.scala | 8 +-
.../scala/unit/kafka/admin/TopicCommandTest.scala | 17 +-
.../admin/TopicCommandWithAdminClientTest.scala | 114 +--
.../kafka/admin/TopicCommandWithZKClientTest.scala | 112 +--
.../admin/UserScramCredentialsCommandTest.scala | 10 +-
.../test/scala/unit/kafka/api/ApiUtilsTest.scala | 20 +-
.../test/scala/unit/kafka/api/ApiVersionTest.scala | 16 +-
.../unit/kafka/cluster/AbstractPartitionTest.scala | 6 +-
.../unit/kafka/cluster/AssignmentStateTest.scala | 61 +-
.../unit/kafka/cluster/BrokerEndPointTest.scala | 4 +-
.../unit/kafka/cluster/PartitionLockTest.scala | 18 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 182 ++--
.../scala/unit/kafka/cluster/ReplicaTest.scala | 12 +-
.../ZkNodeChangeNotificationListenerTest.scala | 6 +-
.../controller/ControllerChannelManagerTest.scala | 21 +-
.../kafka/controller/ControllerContextTest.scala | 10 +-
.../controller/ControllerEventManagerTest.scala | 8 +-
.../kafka/controller/ControllerFailoverTest.scala | 13 +-
.../controller/ControllerIntegrationTest.scala | 43 +-
.../PartitionLeaderElectionAlgorithmsTest.scala | 6 +-
.../controller/PartitionStateMachineTest.scala | 21 +-
.../kafka/controller/ReplicaStateMachineTest.scala | 6 +-
.../controller/TopicDeletionManagerTest.scala | 4 +-
.../AbstractCoordinatorConcurrencyTest.scala | 6 +-
.../group/GroupCoordinatorConcurrencyTest.scala | 8 +-
.../coordinator/group/GroupCoordinatorTest.scala | 46 +-
.../group/GroupMetadataManagerTest.scala | 53 +-
.../coordinator/group/GroupMetadataTest.scala | 58 +-
.../coordinator/group/MemberMetadataTest.scala | 14 +-
.../transaction/ProducerIdManagerTest.scala | 10 +-
.../TransactionCoordinatorConcurrencyTest.scala | 14 +-
.../transaction/TransactionCoordinatorTest.scala | 4 +-
.../transaction/TransactionLogTest.scala | 9 +-
.../TransactionMarkerChannelManagerTest.scala | 8 +-
...sactionMarkerRequestCompletionHandlerTest.scala | 22 +-
.../transaction/TransactionMetadataTest.scala | 28 +-
.../transaction/TransactionStateManagerTest.scala | 25 +-
.../kafka/integration/KafkaServerTestHarness.scala | 6 +-
.../MetricsDuringTopicCreationDeletionTest.scala | 12 +-
.../unit/kafka/integration/MinIsrConfigTest.scala | 2 +-
.../integration/UncleanLeaderElectionTest.scala | 36 +-
.../log/AbstractLogCleanerIntegrationTest.scala | 12 +-
.../unit/kafka/log/BrokerCompressionTest.scala | 35 +-
.../unit/kafka/log/LogCleanerIntegrationTest.scala | 27 +-
.../kafka/log/LogCleanerLagIntegrationTest.scala | 38 +-
.../unit/kafka/log/LogCleanerManagerTest.scala | 63 +-
.../LogCleanerParameterizedIntegrationTest.scala | 89 +-
.../test/scala/unit/kafka/log/LogCleanerTest.scala | 127 +--
.../scala/unit/kafka/log/LogConcurrencyTest.scala | 16 +-
.../test/scala/unit/kafka/log/LogConfigTest.scala | 33 +-
.../test/scala/unit/kafka/log/LogManagerTest.scala | 113 +--
.../test/scala/unit/kafka/log/LogSegmentTest.scala | 24 +-
core/src/test/scala/unit/kafka/log/LogTest.scala | 715 ++++++++--------
.../scala/unit/kafka/log/LogValidatorTest.scala | 213 ++---
.../scala/unit/kafka/log/OffsetIndexTest.scala | 65 +-
.../test/scala/unit/kafka/log/OffsetMapTest.scala | 4 +-
.../unit/kafka/log/ProducerStateManagerTest.scala | 86 +-
.../test/scala/unit/kafka/log/TimeIndexTest.scala | 27 +-
.../unit/kafka/log/TransactionIndexTest.scala | 29 +-
.../scala/unit/kafka/metrics/KafkaTimerTest.scala | 4 +-
.../scala/unit/kafka/metrics/MetricsTest.scala | 19 +-
.../unit/kafka/network/ConnectionQuotasTest.scala | 235 ++---
.../unit/kafka/network/RequestChannelTest.scala | 8 +-
.../kafka/network/RequestConvertToJsonTest.scala | 8 +-
.../unit/kafka/network/SocketServerTest.scala | 58 +-
.../unit/kafka/raft/KafkaNetworkChannelTest.scala | 74 +-
.../scala/unit/kafka/raft/RaftManagerTest.scala | 68 ++
.../unit/kafka/security/auth/OperationTest.scala | 4 +-
.../kafka/security/auth/PermissionTypeTest.scala | 12 +-
.../kafka/security/auth/ResourceTypeTest.scala | 13 +-
.../security/auth/SimpleAclAuthorizerTest.scala | 100 +--
.../kafka/security/auth/ZkAuthorizationTest.scala | 35 +-
.../security/authorizer/AclAuthorizerTest.scala | 118 ++-
.../authorizer/AclAuthorizerWithZkSaslTest.scala | 8 +-
.../kafka/security/authorizer/AclEntryTest.scala | 7 +-
.../AuthorizerInterfaceDefaultTest.scala | 6 +-
.../authorizer/AuthorizerWrapperTest.scala | 30 +-
.../security/authorizer/BaseAuthorizerTest.scala | 172 ++--
.../delegation/DelegationTokenManagerTest.scala | 8 +-
.../server/AbstractApiVersionsRequestTest.scala | 37 +-
.../server/AbstractCreateTopicsRequestTest.scala | 31 +-
.../kafka/server/AbstractFetcherManagerTest.scala | 6 +-
.../kafka/server/AbstractFetcherThreadTest.scala | 15 +-
.../AddPartitionsToTxnRequestServerTest.scala | 6 +-
.../unit/kafka/server/AdvertiseBrokerTest.scala | 6 +-
.../unit/kafka/server/AlterIsrManagerTest.scala | 176 ++--
.../server/AlterReplicaLogDirsRequestTest.scala | 4 +-
...rScramCredentialsRequestNotAuthorizedTest.scala | 79 ++
.../AlterUserScramCredentialsRequestTest.scala | 78 +-
.../unit/kafka/server/ApiVersionsRequestTest.scala | 25 +-
.../scala/unit/kafka/server/AuthHelperTest.scala | 142 +++
.../kafka/server/BaseClientQuotaManagerTest.scala | 4 +-
.../kafka/server/BrokerEpochIntegrationTest.scala | 10 +-
.../unit/kafka/server/BrokerFeaturesTest.scala | 4 +-
.../unit/kafka/server/ClientQuotaManagerTest.scala | 52 +-
.../kafka/server/ClientQuotasRequestTest.scala | 49 +-
.../server/ClientRequestQuotaManagerTest.scala | 14 +-
.../ControllerMutationQuotaManagerTest.scala | 17 +-
.../kafka/server/ControllerMutationQuotaTest.scala | 16 +-
.../kafka/server/CreateTopicsRequestTest.scala | 4 +-
.../CreateTopicsRequestWithForwardingTest.scala | 4 +-
.../server/CreateTopicsRequestWithPolicyTest.scala | 2 +-
.../unit/kafka/server/DelayedOperationTest.scala | 87 +-
.../DelegationTokenRequestsOnPlainTextTest.scala | 16 +-
.../kafka/server/DelegationTokenRequestsTest.scala | 18 +-
...nTokenRequestsWithDisableTokenFeatureTest.scala | 19 +-
.../kafka/server/DeleteTopicsRequestTest.scala | 12 +-
...leteTopicsRequestWithDeletionDisabledTest.scala | 4 +-
.../kafka/server/DescribeClusterRequestTest.scala | 92 ++
.../kafka/server/DescribeLogDirsRequestTest.scala | 6 +-
...rScramCredentialsRequestNotAuthorizedTest.scala | 51 ++
.../DescribeUserScramCredentialsRequestTest.scala | 49 +-
.../kafka/server/DynamicBrokerConfigTest.scala | 43 +-
.../kafka/server/DynamicConfigChangeTest.scala | 80 +-
.../unit/kafka/server/DynamicConfigTest.scala | 40 +-
.../unit/kafka/server/EdgeCaseRequestTest.scala | 14 +-
.../FetchRequestDownConversionConfigTest.scala | 7 +-
.../kafka/server/FetchRequestMaxBytesTest.scala | 14 +-
.../scala/unit/kafka/server/FetchRequestTest.scala | 22 +-
.../scala/unit/kafka/server/FetchSessionTest.scala | 25 +-
.../kafka/server/FinalizedFeatureCacheTest.scala | 12 +-
.../FinalizedFeatureChangeListenerTest.scala | 12 +-
.../unit/kafka/server/ForwardingManagerTest.scala | 52 +-
.../server/HighwatermarkPersistenceTest.scala | 6 +-
.../unit/kafka/server/IsrExpirationTest.scala | 34 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 322 ++++---
.../scala/unit/kafka/server/KafkaConfigTest.scala | 61 +-
.../server/KafkaMetricReporterClusterIdTest.scala | 12 +-
.../KafkaMetricReporterExceptionHandlingTest.scala | 9 +-
.../kafka/server/KafkaMetricsReporterTest.scala | 14 +-
.../scala/unit/kafka/server/KafkaServerTest.scala | 13 +-
.../unit/kafka/server/LeaderElectionTest.scala | 26 +-
.../unit/kafka/server/ListOffsetsRequestTest.scala | 4 +-
.../unit/kafka/server/LogDirFailureTest.scala | 24 +-
.../scala/unit/kafka/server/LogOffsetTest.scala | 4 +-
.../scala/unit/kafka/server/LogRecoveryTest.scala | 20 +-
.../unit/kafka/server/MetadataCacheTest.scala | 72 +-
.../unit/kafka/server/MetadataRequestTest.scala | 59 +-
.../server/OffsetsForLeaderEpochRequestTest.scala | 4 +-
.../unit/kafka/server/ProduceRequestTest.scala | 7 +-
.../server/ReplicaAlterLogDirsThreadTest.scala | 23 +-
.../scala/unit/kafka/server/ReplicaFetchTest.scala | 6 +-
.../kafka/server/ReplicaFetcherThreadTest.scala | 80 +-
.../kafka/server/ReplicaManagerQuotasTest.scala | 42 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 32 +-
.../kafka/server/ReplicationQuotaManagerTest.scala | 6 +-
.../unit/kafka/server/ReplicationQuotasTest.scala | 24 +-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 51 +-
.../kafka/server/SaslApiVersionsRequestTest.scala | 8 +-
.../kafka/server/ServerGenerateBrokerIdTest.scala | 13 +-
.../kafka/server/ServerGenerateClusterIdTest.scala | 17 +-
.../unit/kafka/server/ServerMetricsTest.scala | 15 +-
.../unit/kafka/server/ServerShutdownTest.scala | 8 +-
.../unit/kafka/server/ServerStartupTest.scala | 21 +-
.../unit/kafka/server/StopReplicaRequestTest.scala | 4 +-
.../server/ThrottledChannelExpirationTest.scala | 27 +-
.../unit/kafka/server/UpdateFeaturesTest.scala | 15 +-
...nManagerTest.scala => ZkAdminManagerTest.scala} | 26 +-
.../LeaderEpochCheckpointFileTest.scala | 4 +-
.../checkpoints/OffsetCheckpointFileTest.scala | 13 +-
...chDrivenReplicationProtocolAcceptanceTest.scala | 18 +-
.../server/epoch/LeaderEpochFileCacheTest.scala | 12 +-
.../server/epoch/LeaderEpochIntegrationTest.scala | 6 +-
.../server/epoch/OffsetsForLeaderEpochTest.scala | 8 +-
.../unit/kafka/tools/ConsoleConsumerTest.scala | 73 +-
.../unit/kafka/tools/ConsoleProducerTest.scala | 21 +-
.../unit/kafka/tools/ConsumerPerformanceTest.scala | 14 +-
.../unit/kafka/tools/DumpLogSegmentsTest.scala | 21 +-
.../scala/unit/kafka/tools/MirrorMakerTest.scala | 4 +-
.../unit/kafka/utils/CommandLineUtilsTest.scala | 28 +-
.../scala/unit/kafka/utils/CoreUtilsTest.scala | 12 +-
.../src/test/scala/unit/kafka/utils/JsonTest.scala | 4 +-
.../unit/kafka/utils/PasswordEncoderTest.scala | 10 +-
.../src/test/scala/unit/kafka/utils/PoolTest.scala | 4 +-
.../scala/unit/kafka/utils/QuotaUtilsTest.scala | 14 +-
.../unit/kafka/utils/ReplicationUtilsTest.scala | 6 +-
.../scala/unit/kafka/utils/SchedulerTest.scala | 44 +-
.../unit/kafka/utils/ShutdownableThreadTest.scala | 8 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 97 +--
.../scala/unit/kafka/utils/ThrottlerTest.scala | 5 +-
.../scala/unit/kafka/utils/TopicFilterTest.scala | 4 +-
.../unit/kafka/utils/json/JsonValueTest.scala | 4 +-
.../unit/kafka/utils/timer/TimerTaskListTest.scala | 4 +-
.../scala/unit/kafka/utils/timer/TimerTest.scala | 14 +-
.../scala/unit/kafka/zk/AdminZkClientTest.scala | 56 +-
.../scala/unit/kafka/zk/KafkaZkClientTest.scala | 159 ++--
.../kafka/zk/ReassignPartitionsZNodeTest.scala | 7 +-
.../scala/unit/kafka/zk/ZooKeeperTestHarness.scala | 24 +-
.../unit/kafka/zookeeper/ZooKeeperClientTest.scala | 179 ++--
docs/ops.html | 147 +++-
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 | 23 +-
.../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 | 6 +-
gradle/spotbugs-exclude.xml | 7 +
gradle/wrapper/gradle-wrapper.properties | 2 +-
gradlew | 4 +-
jenkins.sh | 77 --
.../jmh/metadata/MetadataRequestBenchmark.java | 4 +-
.../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 | 70 ++
.../common/metadata/AccessControlRecord.json | 37 +
.../resources/common/metadata/ConfigRecord.json | 28 +-
.../common/metadata/DelegationTokenRecord.json | 32 +-
.../common/metadata/FeatureLevelRecord.json | 26 +-
.../common/metadata/FenceBrokerRecord.json | 24 +-
.../resources/common/metadata/IsrChangeRecord.json | 30 +-
.../resources/common/metadata/PartitionRecord.json | 39 +
.../resources/common/metadata/QuotaRecord.json | 36 +
.../common/metadata/RegisterBrokerRecord.json | 51 ++
.../common/metadata/RemoveTopicRecord.json | 22 +-
.../resources/common/metadata/TopicRecord.json | 24 +-
.../common/metadata/UnfenceBrokerRecord.json | 24 +-
.../common/metadata/UnregisterBrokerRecord.json | 24 +-
.../common/metadata/UserScramCredentialRecord.json | 35 +
.../org/apache/kafka/metadata/BrokerStateTest.java | 29 +-
.../apache/kafka/metadata/MetadataParserTest.java | 155 ++++
.../apache/kafka/metadata/VersionRangeTest.java | 61 ++
metadata/src/test/resources/log4j.properties | 22 +
.../org/apache/kafka/raft/KafkaRaftClient.java | 141 +--
.../java/org/apache/kafka/raft/QuorumState.java | 52 +-
.../java/org/apache/kafka/raft/RaftClient.java | 18 +-
.../java/org/apache/kafka/raft/RaftConfig.java | 43 +-
.../kafka/raft/internals/KafkaRaftMetrics.java | 2 +-
.../org/apache/kafka/snapshot/SnapshotWriter.java | 2 +-
.../kafka/raft/KafkaRaftClientSnapshotTest.java | 6 +-
.../org/apache/kafka/raft/KafkaRaftClientTest.java | 165 ++--
.../org/apache/kafka/raft/QuorumStateTest.java | 41 +
.../apache/kafka/raft/RaftClientTestContext.java | 62 +-
.../java/org/apache/kafka/raft/RaftConfigTest.java | 1 -
.../apache/kafka/raft/RaftEventSimulationTest.java | 76 +-
.../java/org/apache/kafka/raft/RaftTestUtil.java | 65 ++
.../kafka/raft/internals/KafkaRaftMetricsTest.java | 3 +-
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 | 160 +++-
.../org/apache/kafka/streams/StreamsConfig.java | 3 +-
.../errors/DeserializationExceptionHandler.java | 6 +
.../streams/processor/internals/AbstractTask.java | 7 +-
.../processor/internals/ActiveTaskCreator.java | 12 +-
.../processor/internals/GlobalStreamThread.java | 4 +
.../streams/processor/internals/StandbyTask.java | 4 +-
.../processor/internals/StandbyTaskCreator.java | 12 +-
.../streams/processor/internals/StreamTask.java | 17 +-
.../streams/processor/internals/StreamThread.java | 36 +-
.../internals/StreamsRebalanceListener.java | 1 +
.../kafka/streams/processor/internals/Task.java | 173 ++--
.../streams/processor/internals/TaskManager.java | 201 ++---
.../kafka/streams/processor/internals/Tasks.java | 295 +++++++
.../state/internals/InMemoryKeyValueStore.java | 4 +-
.../kafka/streams/state/internals/ThreadCache.java | 5 +-
.../state/internals/metrics/RocksDBMetrics.java | 6 +-
.../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 | 224 ++++-
.../integration/EosBetaUpgradeIntegrationTest.java | 58 +-
.../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/PartitionGroupTest.java | 10 +-
.../processor/internals/ProcessorNodeTest.java | 9 +-
.../internals/StateRestoreCallbackAdapterTest.java | 9 +-
.../internals/StoreChangelogReaderTest.java | 4 +-
.../processor/internals/StreamTaskTest.java | 261 ++++--
.../processor/internals/StreamThreadTest.java | 2 +
.../internals/StreamsMetadataStateTest.java | 21 +-
.../internals/StreamsRebalanceListenerTest.java | 6 +-
.../processor/internals/TaskManagerTest.java | 42 +-
.../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 +-
.../internals/metrics/RocksDBMetricsTest.java | 6 +-
.../kafka/streams/tests/SystemTestUtilTest.java | 13 +-
.../apache/kafka/streams/TopologyTestDriver.java | 2 -
.../kafka/streams/MockProcessorContextTest.java | 12 +-
.../org/apache/kafka/streams/MockTimeTest.java | 10 +-
.../org/apache/kafka/streams/TestTopicsTest.java | 57 +-
.../streams/TopologyTestDriverAtLeastOnceTest.java | 12 +-
.../kafka/streams/TopologyTestDriverEosTest.java | 12 +-
.../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 +-
wrapper.gradle | 2 +-
882 files changed, 17794 insertions(+), 15015 deletions(-)
delete mode 100644
clients/src/main/java/org/apache/kafka/clients/ApiVersion.java
create mode 100644
clients/src/main/java/org/apache/kafka/common/requests/DescribeClusterRequest.java
create mode 100644
clients/src/main/java/org/apache/kafka/common/requests/DescribeClusterResponse.java
copy clients/src/main/resources/common/message/{OffsetDeleteRequest.json =>
DescribeClusterRequest.json} (53%)
create mode 100644
clients/src/main/resources/common/message/DescribeClusterResponse.json
copy
clients/src/test/java/org/apache/kafka/{common/utils/LoggingSignalHandlerTest.java
=> clients/consumer/internals/CooperativeConsumerCoordinatorTest.java} (71%)
copy
clients/src/test/java/org/apache/kafka/{common/utils/LoggingSignalHandlerTest.java
=> clients/consumer/internals/EagerConsumerCoordinatorTest.java} (72%)
copy
clients/src/test/java/org/apache/kafka/common/{utils/LoggingSignalHandlerTest.java
=> security/authenticator/SaslAuthenticatorFailureNoDelayTest.java} (77%)
copy
clients/src/test/java/org/apache/kafka/common/{utils/LoggingSignalHandlerTest.java
=> security/authenticator/SaslAuthenticatorFailurePositiveDelayTest.java} (77%)
copy
clients/src/test/java/org/apache/kafka/common/{utils/LoggingSignalHandlerTest.java
=> security/ssl/Tls12SslFactoryTest.java} (77%)
copy
clients/src/test/java/org/apache/kafka/common/{utils/LoggingSignalHandlerTest.java
=> 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/test/java/org/apache/kafka/common/utils/LoggingSignalHandlerTest.java
=>
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationTest.java
(79%)
create mode 100644 core/src/main/scala/kafka/raft/RaftManager.scala
create mode 100644 core/src/main/scala/kafka/server/AuthHelper.scala
copy
clients/src/test/java/org/apache/kafka/common/utils/LoggingSignalHandlerTest.java
=> core/src/main/scala/kafka/server/BrokerServer.scala (74%)
copy
clients/src/test/java/org/apache/kafka/common/utils/LoggingSignalHandlerTest.java
=> core/src/main/scala/kafka/server/ControllerServer.scala (73%)
create mode 100644 core/src/main/scala/kafka/server/KafkaRaftServer.scala
delete mode 100644 core/src/main/scala/kafka/server/KafkaServerStartable.scala
create mode 100644 core/src/main/scala/kafka/server/RequestHandlerHelper.scala
create mode 100644 core/src/main/scala/kafka/server/Server.scala
rename core/src/main/scala/kafka/server/{AdminManager.scala =>
ZkAdminManager.scala} (98%)
create mode 100644 core/src/test/scala/unit/kafka/raft/RaftManagerTest.scala
create mode 100644
core/src/test/scala/unit/kafka/server/AlterUserScramCredentialsRequestNotAuthorizedTest.scala
create mode 100644 core/src/test/scala/unit/kafka/server/AuthHelperTest.scala
create mode 100644
core/src/test/scala/unit/kafka/server/DescribeClusterRequestTest.scala
create mode 100644
core/src/test/scala/unit/kafka/server/DescribeUserScramCredentialsRequestNotAuthorizedTest.scala
rename core/src/test/scala/unit/kafka/server/{AdminManagerTest.scala =>
ZkAdminManagerTest.scala} (85%)
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
delete mode 100755 jenkins.sh
create mode 100644
metadata/src/main/java/org/apache/kafka/metadata/BrokerState.java
copy
clients/src/main/java/org/apache/kafka/common/errors/PrincipalDeserializationException.java
=>
metadata/src/main/java/org/apache/kafka/metadata/MetadataParseException.java
(76%)
create mode 100644
metadata/src/main/java/org/apache/kafka/metadata/MetadataParser.java
create mode 100644
metadata/src/main/java/org/apache/kafka/metadata/VersionRange.java
create mode 100644
metadata/src/main/resources/common/metadata/AccessControlRecord.json
copy clients/src/main/resources/common/message/OffsetDeleteRequest.json =>
metadata/src/main/resources/common/metadata/ConfigRecord.json (52%)
copy clients/src/main/resources/common/message/OffsetDeleteRequest.json =>
metadata/src/main/resources/common/metadata/DelegationTokenRecord.json (50%)
copy clients/src/main/resources/common/message/OffsetDeleteRequest.json =>
metadata/src/main/resources/common/metadata/FeatureLevelRecord.json (52%)
copy clients/src/main/resources/common/message/OffsetDeleteRequest.json =>
metadata/src/main/resources/common/metadata/FenceBrokerRecord.json (52%)
copy clients/src/main/resources/common/message/OffsetDeleteRequest.json =>
metadata/src/main/resources/common/metadata/IsrChangeRecord.json (52%)
create mode 100644
metadata/src/main/resources/common/metadata/PartitionRecord.json
create mode 100644 metadata/src/main/resources/common/metadata/QuotaRecord.json
create mode 100644
metadata/src/main/resources/common/metadata/RegisterBrokerRecord.json
copy clients/src/main/resources/common/message/OffsetDeleteRequest.json =>
metadata/src/main/resources/common/metadata/RemoveTopicRecord.json (52%)
copy clients/src/main/resources/common/message/OffsetDeleteRequest.json =>
metadata/src/main/resources/common/metadata/TopicRecord.json (52%)
copy clients/src/main/resources/common/message/OffsetDeleteRequest.json =>
metadata/src/main/resources/common/metadata/UnfenceBrokerRecord.json (52%)
copy clients/src/main/resources/common/message/OffsetDeleteRequest.json =>
metadata/src/main/resources/common/metadata/UnregisterBrokerRecord.json (52%)
create mode 100644
metadata/src/main/resources/common/metadata/UserScramCredentialRecord.json
copy
clients/src/test/java/org/apache/kafka/common/metrics/internals/MetricsUtilsTest.java
=> metadata/src/test/java/org/apache/kafka/metadata/BrokerStateTest.java (54%)
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
create mode 100644 metadata/src/test/resources/log4j.properties
create mode 100644 raft/src/test/java/org/apache/kafka/raft/RaftTestUtil.java
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java
copy
clients/src/test/java/org/apache/kafka/common/utils/LoggingSignalHandlerTest.java
=>
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverAtLeastOnceTest.java
(73%)
copy
clients/src/test/java/org/apache/kafka/common/utils/LoggingSignalHandlerTest.java
=>
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverEosTest.java
(74%)
