"Fossies" - the Fresh Open Source Software Archive  

Source code changes report for "kafka" between the packages
kafka-2.6.0-src.tgz and kafka-2.7.0-src.tgz

About: Apache kafka is a distributed streaming platform.

Summary:

The "kafka" source code changed by about 11.2% and now consists of 3898 regular files (+272) and 859 directories (+43).

Related Informations:

None found by Fossies.

Changes In Files (According File Type):

File TypeTotalAddedRemovedChanged
C program 131 12 0 61
Java program 2763 209 7 654
Python program 139 1 0 55
Shell program 48 2 0 5
Ruby program 1 0 0 0
Configuration file 8 1 0 0
JavaScript file 1 0 0 1
JSON file 131 21 0 21
XML document 10 0 0 8
DOS Batch file 27 0 0 1
Git file 8 0 0 1
HTML page 63 2 1 33
Log file 36 0 0 16
Property file 50 3 0 6
RDF file 1 0 0 0
XML style sheet 1 0 0 0
YAML file 2 0 0 1
Image file 50 1 0 0
Directory 859 43 0 0
Information file 3 0 0 0
License 1 0 0 0
Readme file 8 1 0 3
Text file 422 27 0 169
Other 2 0 0 0
Total Files476532381035



C Programs (73 of 131):

NameStatusDeltaVisual Diff
core/src/main/scala/kafka/admin/AclCommand.scala changed 3.5% diff
core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala changed 9.9% diff
core/src/main/scala/kafka/admin/ConfigCommand.scala changed 21.8% diff
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala changed 1.2% diff
core/src/main/scala/kafka/admin/FeatureCommand.scala added
core/src/main/scala/kafka/admin/LeaderElectionCommand.scala changed 0.8% diff
core/src/main/scala/kafka/admin/LogDirsCommand.scala changed 8.0% diff
core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala changed 2.2% diff
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala changed 9.0% diff
core/src/main/scala/kafka/admin/TopicCommand.scala changed 6.6% diff
core/src/main/scala/kafka/admin/ZkSecurityMigrator.scala changed 2.3% diff
core/src/main/scala/kafka/common/ZkNodeChangeNotificationListener.scala changed 4.1% diff
core/src/main/scala/kafka/controller/ControllerContext.scala changed 29.7% diff
core/src/main/scala/kafka/network/RequestChannel.scala changed 1.3% diff
core/src/main/scala/kafka/tools/ConsoleConsumer.scala changed 23.9% diff
core/src/main/scala/kafka/tools/ConsoleProducer.scala changed 2.0% diff
core/src/main/scala/kafka/tools/ConsumerPerformance.scala changed 4.6% diff
core/src/main/scala/kafka/tools/DumpLogSegments.scala changed 1.0% diff
core/src/main/scala/kafka/tools/GetOffsetShell.scala changed 1.5% diff
core/src/main/scala/kafka/tools/JmxTool.scala changed 7.8% diff
core/src/main/scala/kafka/tools/MirrorMaker.scala changed 0.4% diff
core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala changed 2.1% diff
core/src/main/scala/kafka/tools/StateChangeLogMerger.scala changed 1.2% diff
core/src/main/scala/org/apache/zookeeper/ZooKeeperMainWithTlsSupportForKafka.scala changed 1.0% diff
core/src/test/scala/kafka/common/InterBrokerSendThreadTest.scala changed 8.8% diff
core/src/test/scala/kafka/server/BrokerToControllerRequestThreadTest.scala added
core/src/test/scala/kafka/utils/ExitTest.scala changed 4.5% diff
core/src/test/scala/kafka/zk/FeatureZNodeTest.scala added
core/src/test/scala/other/kafka/ReplicationQuotasTestRig.scala changed 0.4% diff
core/src/test/scala/unit/kafka/admin/AclCommandTest.scala changed 26.6% diff
core/src/test/scala/unit/kafka/admin/ReassignPartitionsUnitTest.scala changed 4.4% diff
core/src/test/scala/unit/kafka/cluster/AbstractPartitionTest.scala changed 10.7% diff
core/src/test/scala/unit/kafka/cluster/BrokerEndPointTest.scala changed 22.2% diff
core/src/test/scala/unit/kafka/controller/ControllerChannelManagerTest.scala changed 4.1% diff
core/src/test/scala/unit/kafka/controller/ControllerContextTest.scala changed 30.4% diff
core/src/test/scala/unit/kafka/controller/ControllerEventManagerTest.scala changed 18.7% diff
core/src/test/scala/unit/kafka/controller/PartitionStateMachineTest.scala changed 2.1% diff
core/src/test/scala/unit/kafka/controller/ReplicaStateMachineTest.scala changed 2.5% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorTest.scala changed 4.6% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala changed 3.3% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorTest.scala changed 1.7% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMetadataTest.scala changed 0.3% diff
core/src/test/scala/unit/kafka/KafkaConfigTest.scala changed 8.0% diff
core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala changed 100.0% diff
core/src/test/scala/unit/kafka/network/SocketServerTest.scala changed 1.1% diff
core/src/test/scala/unit/kafka/raft/KafkaFuturePurgatoryTest.scala added
core/src/test/scala/unit/kafka/raft/KafkaNetworkChannelTest.scala added
core/src/test/scala/unit/kafka/server/AdminManagerTest.scala added
core/src/test/scala/unit/kafka/server/AlterIsrManagerTest.scala added
core/src/test/scala/unit/kafka/server/BaseClientQuotaManagerTest.scala added
core/src/test/scala/unit/kafka/server/BrokerFeaturesTest.scala added
core/src/test/scala/unit/kafka/server/ControllerMutationQuotaManagerTest.scala added
core/src/test/scala/unit/kafka/server/DelayedOperationTest.scala changed 13.2% diff
core/src/test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala changed 4.5% diff
core/src/test/scala/unit/kafka/server/epoch/LeaderEpochFileCacheTest.scala changed 4.1% diff
core/src/test/scala/unit/kafka/server/epoch/OffsetsForLeaderEpochTest.scala changed 7.8% diff
core/src/test/scala/unit/kafka/server/FetchSessionTest.scala changed 22.5% diff
core/src/test/scala/unit/kafka/server/FinalizedFeatureCacheTest.scala added
core/src/test/scala/unit/kafka/server/HighwatermarkPersistenceTest.scala changed 6.1% diff
core/src/test/scala/unit/kafka/server/IsrExpirationTest.scala changed 2.2% diff
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala changed 20.8% diff
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala changed 30.4% diff
core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala changed 8.2% diff
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala changed 1.0% diff
core/src/test/scala/unit/kafka/server/ReplicaManagerQuotasTest.scala changed 1.9% diff
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala changed 3.2% diff
core/src/test/scala/unit/kafka/tools/ConsoleConsumerTest.scala changed 17.3% diff
core/src/test/scala/unit/kafka/tools/ConsumerPerformanceTest.scala changed 8.1% diff
core/src/test/scala/unit/kafka/tools/DumpLogSegmentsTest.scala changed 0.5% diff
core/src/test/scala/unit/kafka/utils/QuotaUtilsTest.scala added
core/src/test/scala/unit/kafka/utils/ThrottlerTest.scala changed 2.3% diff
core/src/test/scala/unit/kafka/utils/TopicFilterTest.scala changed 35.0% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/TopologyTest.scala changed 12.9% diff

Java Programs (870 of 2763):

NameStatusDeltaVisual Diff
clients/src/main/java/org/apache/kafka/clients/admin/Admin.java changed 16.0% diff
clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java changed 11.7% diff
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsOptions.java changed 4.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/AlterUserScramCredentialsOptions.java added
clients/src/main/java/org/apache/kafka/clients/admin/AlterUserScramCredentialsResult.java added
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsOptions.java changed 29.7% diff
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsOptions.java changed 24.8% diff
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsOptions.java changed 32.1% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeFeaturesOptions.java added
clients/src/main/java/org/apache/kafka/clients/admin/DescribeFeaturesResult.java added
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsResult.java changed 100.0% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsOptions.java added
clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResult.java added
clients/src/main/java/org/apache/kafka/clients/admin/FeatureMetadata.java added
clients/src/main/java/org/apache/kafka/clients/admin/FeatureUpdate.java added
clients/src/main/java/org/apache/kafka/clients/admin/FinalizedVersionRange.java added
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java changed 26.6% diff
clients/src/main/java/org/apache/kafka/clients/admin/LogDirDescription.java added
clients/src/main/java/org/apache/kafka/clients/admin/NewTopic.java changed 6.3% diff
clients/src/main/java/org/apache/kafka/clients/admin/ReplicaInfo.java added
clients/src/main/java/org/apache/kafka/clients/admin/ScramCredentialInfo.java added
clients/src/main/java/org/apache/kafka/clients/admin/ScramMechanism.java added
clients/src/main/java/org/apache/kafka/clients/admin/SupportedVersionRange.java added
clients/src/main/java/org/apache/kafka/clients/admin/UpdateFeaturesOptions.java added
clients/src/main/java/org/apache/kafka/clients/admin/UpdateFeaturesResult.java added
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialAlteration.java added
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialDeletion.java added
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialsDescription.java added
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialUpsertion.java added
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java changed 31.4% diff
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java changed 9.1% diff
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java changed 5.5% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java changed 14.6% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java changed 4.4% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java changed 1.9% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java changed 86.3% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java changed 10.6% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Heartbeat.java changed 13.5% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java changed 4.8% diff
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java changed 1.6% diff
clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java changed 1.7% diff
clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java changed 0.5% diff
clients/src/main/java/org/apache/kafka/clients/ManualMetadataUpdater.java changed 1.5% diff
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java changed 4.4% diff
clients/src/main/java/org/apache/kafka/clients/NodeApiVersions.java changed 1.2% diff
clients/src/main/java/org/apache/kafka/clients/producer/Callback.java changed 2.0% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java changed 0.4% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java changed 4.4% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/SenderMetricsRegistry.java changed 3.6% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java changed 2.3% diff
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java changed 3.1% diff
clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java changed 1.8% diff
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java changed 8.9% diff
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java changed 0.8% diff
clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java changed 0.2% diff
clients/src/main/java/org/apache/kafka/common/config/internals/BrokerSecurityConfigs.java changed 3.7% diff
clients/src/main/java/org/apache/kafka/common/config/provider/DirectoryConfigProvider.java added
clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java changed 19.7% diff
clients/src/main/java/org/apache/kafka/common/errors/DuplicateResourceException.java added
clients/src/main/java/org/apache/kafka/common/errors/FeatureUpdateFailedException.java added
clients/src/main/java/org/apache/kafka/common/errors/InconsistentVoterSetException.java added
clients/src/main/java/org/apache/kafka/common/errors/InvalidProducerEpochException.java added
clients/src/main/java/org/apache/kafka/common/errors/InvalidUpdateVersionException.java added
clients/src/main/java/org/apache/kafka/common/errors/ResourceNotFoundException.java added
clients/src/main/java/org/apache/kafka/common/errors/RetriableException.java changed 6.0% diff
clients/src/main/java/org/apache/kafka/common/errors/ThrottlingQuotaExceededException.java added
clients/src/main/java/org/apache/kafka/common/errors/TransactionAbortedException.java added
clients/src/main/java/org/apache/kafka/common/errors/UnacceptableCredentialException.java added
clients/src/main/java/org/apache/kafka/common/feature/BaseVersionRange.java added
clients/src/main/java/org/apache/kafka/common/feature/Features.java added
clients/src/main/java/org/apache/kafka/common/feature/FinalizedVersionRange.java added
clients/src/main/java/org/apache/kafka/common/feature/SupportedVersionRange.java added
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java changed 23.1% diff
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java changed 3.9% diff
clients/src/main/java/org/apache/kafka/common/MessageFormatter.java added
clients/src/main/java/org/apache/kafka/common/metrics/internals/MetricsUtils.java added
clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java changed 14.6% diff
clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java changed 0.6% diff
clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java changed 20.5% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java changed 16.0% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java added
clients/src/main/java/org/apache/kafka/common/network/PlaintextChannelBuilder.java changed 10.6% diff
clients/src/main/java/org/apache/kafka/common/network/Selector.java changed 1.4% diff
clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java changed 0.6% diff
clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java changed 0.5% diff
clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java changed 22.3% diff
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java changed 9.8% diff
clients/src/main/java/org/apache/kafka/common/protocol/Message.java changed 31.7% diff
clients/src/main/java/org/apache/kafka/common/protocol/MessageUtil.java changed 10.1% diff
clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java changed 0.7% diff
clients/src/main/java/org/apache/kafka/common/protocol/RecordsReadable.java added
clients/src/main/java/org/apache/kafka/common/protocol/RecordsWritable.java added
clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java changed 8.1% diff
clients/src/main/java/org/apache/kafka/common/record/ControlRecordType.java changed 5.9% diff
clients/src/main/java/org/apache/kafka/common/record/ControlRecordUtils.java added
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java changed 0.7% diff
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java changed 4.6% diff
clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java changed 5.6% diff
clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java changed 2.8% diff
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java changed 9.7% diff
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequestResponse.java changed 0.2% diff
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java changed 12.7% diff
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java changed 4.0% diff
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponse.java changed 1.9% diff
clients/src/main/java/org/apache/kafka/common/requests/AlterIsrRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/AlterIsrResponse.java added
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsRequest.java changed 75.1% diff
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java changed 76.4% diff
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsResponse.java added
clients/src/main/java/org/apache/kafka/common/requests/ApiError.java changed 3.6% diff
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java changed 91.8% diff
clients/src/main/java/org/apache/kafka/common/requests/BeginQuorumEpochRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/BeginQuorumEpochResponse.java added
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsRequest.java changed 82.7% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java changed 72.3% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java changed 21.1% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeQuorumRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/DescribeQuorumResponse.java added
clients/src/main/java/org/apache/kafka/common/requests/DescribeUserScramCredentialsRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/DescribeUserScramCredentialsResponse.java added
clients/src/main/java/org/apache/kafka/common/requests/EndQuorumEpochRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/EndQuorumEpochResponse.java added
clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java changed 3.9% diff
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java changed 65.9% diff
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java changed 75.6% diff
clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdResponse.java changed 14.1% diff
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java changed 0.9% diff
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java changed 77.2% diff
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java changed 79.0% diff
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaRequest.java changed 0.7% diff
clients/src/main/java/org/apache/kafka/common/requests/UpdateFeaturesRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/UpdateFeaturesResponse.java added
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataRequest.java changed 0.7% diff
clients/src/main/java/org/apache/kafka/common/requests/VoteRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/VoteResponse.java added
clients/src/main/java/org/apache/kafka/common/security/auth/SslEngineFactory.java changed 57.8% diff
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java changed 1.6% diff
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java changed 1.1% diff
clients/src/main/java/org/apache/kafka/common/security/JaasContext.java changed 3.4% diff
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosLogin.java changed 1.4% diff
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramFormatter.java changed 13.0% diff
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClient.java changed 1.5% diff
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslServer.java changed 0.6% diff
clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java changed 100.0% diff
clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java changed 10.8% diff
clients/src/main/java/org/apache/kafka/common/security/ssl/SslPrincipalMapper.java changed 1.7% diff
clients/src/main/java/org/apache/kafka/common/utils/AppInfoParser.java changed 1.7% diff
clients/src/main/java/org/apache/kafka/common/utils/ConfigUtils.java added
clients/src/main/java/org/apache/kafka/common/utils/ExponentialBackoff.java added
clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollection.java changed 9.2% diff
clients/src/main/java/org/apache/kafka/common/utils/Time.java changed 5.8% diff
clients/src/main/java/org/apache/kafka/common/utils/Timer.java changed 11.7% diff
clients/src/main/java/org/apache/kafka/common/utils/Utils.java changed 6.1% diff
clients/src/main/java/org/apache/kafka/server/quota/ClientQuotaType.java changed 3.9% diff
clients/src/test/java/org/apache/kafka/clients/admin/AdminClientTestUtils.java changed 100.0% diff
clients/src/test/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResultTest.java added
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java changed 42.7% diff
clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java changed 2.3% diff
clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java changed 8.1% diff
clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java changed 34.5% diff
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerConfigTest.java changed 6.7% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java changed 4.1% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java changed 4.8% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java changed 0.5% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClientTest.java changed 0.8% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocolTest.java changed 39.8% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java changed 6.0% diff
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java changed 6.7% diff
clients/src/test/java/org/apache/kafka/clients/consumer/RoundRobinAssignorTest.java changed 0.5% diff
clients/src/test/java/org/apache/kafka/clients/consumer/StickyAssignorTest.java changed 1.9% diff
clients/src/test/java/org/apache/kafka/clients/MockClient.java changed 2.2% diff
clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java changed 9.4% diff
clients/src/test/java/org/apache/kafka/clients/NodeApiVersionsTest.java changed 4.4% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java changed 8.4% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java changed 5.5% diff
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java changed 6.7% diff
clients/src/test/java/org/apache/kafka/clients/producer/MockProducerTest.java changed 1.6% diff
clients/src/test/java/org/apache/kafka/clients/producer/ProducerConfigTest.java added
clients/src/test/java/org/apache/kafka/common/config/AbstractConfigTest.java changed 1.4% diff
clients/src/test/java/org/apache/kafka/common/config/provider/DirectoryConfigProviderTest.java added
clients/src/test/java/org/apache/kafka/common/feature/FeaturesTest.java added
clients/src/test/java/org/apache/kafka/common/feature/FinalizedVersionRangeTest.java added
clients/src/test/java/org/apache/kafka/common/feature/SupportedVersionRangeTest.java added
clients/src/test/java/org/apache/kafka/common/memory/GarbageCollectedMemoryPoolTest.java changed 0.4% diff
clients/src/test/java/org/apache/kafka/common/message/MessageTest.java changed 10.1% diff
clients/src/test/java/org/apache/kafka/common/message/RecordsSerdeTest.java added
clients/src/test/java/org/apache/kafka/common/message/SimpleExampleMessageTest.java changed 22.3% diff
clients/src/test/java/org/apache/kafka/common/metrics/JmxReporterTest.java changed 1.1% diff
clients/src/test/java/org/apache/kafka/common/metrics/SensorTest.java changed 84.0% diff
clients/src/test/java/org/apache/kafka/common/metrics/TokenBucketTest.java added
clients/src/test/java/org/apache/kafka/common/network/CertStores.java changed 73.0% diff
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java changed 3.4% diff
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java changed 18.4% diff
clients/src/test/java/org/apache/kafka/common/protocol/ApiKeysTest.java changed 22.6% diff
clients/src/test/java/org/apache/kafka/common/protocol/MessageUtilTest.java changed 100.0% diff
clients/src/test/java/org/apache/kafka/common/protocol/ProtoUtilsTest.java changed 35.2% diff
clients/src/test/java/org/apache/kafka/common/protocol/RecordsWritableTest.java added
clients/src/test/java/org/apache/kafka/common/protocol/types/TypeTest.java added
clients/src/test/java/org/apache/kafka/common/record/ControlRecordUtilsTest.java added
clients/src/test/java/org/apache/kafka/common/record/DefaultRecordTest.java changed 0.3% diff
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsBuilderTest.java changed 6.7% diff
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsTest.java changed 4.1% diff
clients/src/test/java/org/apache/kafka/common/requests/AlterReplicaLogDirsRequestTest.java added
clients/src/test/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponseTest.java added
clients/src/test/java/org/apache/kafka/common/requests/ApiVersionsResponseTest.java changed 77.9% diff
clients/src/test/java/org/apache/kafka/common/requests/ListOffsetRequestTest.java added
clients/src/test/java/org/apache/kafka/common/requests/RequestContextTest.java changed 1.7% diff
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java changed 16.2% diff
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java changed 1.4% diff
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCrede
ntialRefreshingLoginTest.java
changed 0.2% diff
clients/src/test/java/org/apache/kafka/common/security/scram/internals/ScramFormatterTest.java changed 10.5% diff
clients/src/test/java/org/apache/kafka/common/security/scram/internals/ScramMessagesTest.java changed 1.0% diff
clients/src/test/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactoryTest.java added
clients/src/test/java/org/apache/kafka/common/security/ssl/SslFactoryTest.java changed 19.2% diff
clients/src/test/java/org/apache/kafka/common/utils/ConfigUtilsTest.java added
clients/src/test/java/org/apache/kafka/common/utils/ExponentialBackoffTest.java added
clients/src/test/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollectionTest.java changed 7.2% diff
clients/src/test/java/org/apache/kafka/common/utils/MockScheduler.java changed 2.5% diff
clients/src/test/java/org/apache/kafka/common/utils/MockTime.java changed 8.7% diff
clients/src/test/java/org/apache/kafka/common/utils/TimerTest.java changed 21.3% diff
clients/src/test/java/org/apache/kafka/common/utils/UtilsTest.java changed 9.4% diff
clients/src/test/java/org/apache/kafka/test/MockSelector.java changed 5.9% diff
clients/src/test/java/org/apache/kafka/test/TestSslUtils.java changed 74.7% diff
clients/src/test/java/org/apache/kafka/test/TestUtils.java changed 3.1% diff
connect/api/src/main/java/org/apache/kafka/connect/data/Values.java changed 0.8% diff
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java changed 0.8% diff
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java changed 2.7% diff
connect/api/src/test/java/org/apache/kafka/connect/data/ValuesTest.java changed 17.4% diff
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java changed 0.1% diff
connect/json/src/test/java/org/apache/kafka/connect/json/JsonConverterTest.java changed 2.8% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultConfigPropertyFilter.java changed 76.3% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultGroupFilter.java changed 67.3% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultTopicFilter.java changed 67.0% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/CheckpointFormatter.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/HeartbeatFormatter.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/OffsetSyncFormatter.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java changed 99.8% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java changed 18.4% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java changed 10.7% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSync.java changed 2.0% diff
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorCheckpointTaskTest.java changed 73.6% diff
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorConfigTest.java changed 15.4% diff
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java changed 100.0% diff
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorMakerConfigTest.java changed 26.4% diff
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceConnectorTest.java changed 16.1% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java changed 0.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java changed 3.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java changed 0.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java changed 1.8% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.ja
va
changed 10.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java changed 2.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/util/SSLUtils.java changed 10.6% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java changed 1.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java changed 5.8% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java changed 4.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java changed 1.2% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java changed 4.2% diff
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java changed 3.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/util/ReflectionsUtil.java removed
connect/runtime/src/main/java/org/apache/kafka/connect/util/SafeObjectInputStream.java changed 3.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java changed 1.7% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TransformationIntegrationTest.ja
va
changed 10.8% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractHerderTest.java changed 22.8% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.ja
va
changed 0.4% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperatorTes
t.java
changed 30.1% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoaderTest.
java
changed 1.1% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskTest.java changed 4.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java changed 0.4% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/TopicAdminTest.java changed 3.7% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/TopicCreationTest.java changed 31.6% diff
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java changed 16.7% diff
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampRouter.java changed 0.8% diff
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ReplaceFieldTest.java changed 33.3% diff
core/src/main/scala/kafka/tools/StreamsResetter.java changed 5.3% diff
generator/src/main/java/org/apache/kafka/message/ApiMessageTypeGenerator.java changed 3.4% diff
generator/src/main/java/org/apache/kafka/message/FieldSpec.java changed 100.0% diff
generator/src/main/java/org/apache/kafka/message/FieldType.java changed 28.8% diff
generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java added
generator/src/main/java/org/apache/kafka/message/MessageClassGenerator.java added
generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java changed 29.2% diff
generator/src/main/java/org/apache/kafka/message/MessageGenerator.java changed 45.5% diff
generator/src/main/java/org/apache/kafka/message/MessageSpec.java changed 1.0% diff
generator/src/main/java/org/apache/kafka/message/SchemaGenerator.java changed 6.1% diff
generator/src/main/java/org/apache/kafka/message/StructRegistry.java changed 46.6% diff
generator/src/main/java/org/apache/kafka/message/TypeClassGenerator.java added
generator/src/test/java/org/apache/kafka/message/StructRegistryTest.java changed 1.9% diff
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/FetchRequestBenchmark.java added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/FetchResponseBenchmark.java added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/consumer/SubscriptionStateBenchmark.java added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java changed 3.4% diff
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/MetadataRequestBenchmark.java changed 6.7% diff
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java changed 5.1% diff
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java changed 5.1% diff
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/BaseRecordBatchBenchmark.java added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/CompressedRecordBatchValidationBenchmark.j
ava
added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchIterationBenchmark.java changed 57.9% diff
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/UncompressedRecordBatchValidationBenchmark
.java
added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/CheckpointBench.java changed 2.6% diff
log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java changed 5.1% diff
raft/src/main/java/org/apache/kafka/raft/AckMode.java added
raft/src/main/java/org/apache/kafka/raft/CandidateState.java added
raft/src/main/java/org/apache/kafka/raft/ElectionState.java added
raft/src/main/java/org/apache/kafka/raft/EpochState.java added
raft/src/main/java/org/apache/kafka/raft/FileBasedStateStore.java added
raft/src/main/java/org/apache/kafka/raft/FollowerState.java added
raft/src/main/java/org/apache/kafka/raft/FuturePurgatory.java added
raft/src/main/java/org/apache/kafka/raft/internals/KafkaRaftMetrics.java added
raft/src/main/java/org/apache/kafka/raft/internals/LogOffset.java added
raft/src/main/java/org/apache/kafka/raft/Isolation.java added
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java added
raft/src/main/java/org/apache/kafka/raft/LeaderAndEpoch.java added
raft/src/main/java/org/apache/kafka/raft/LeaderState.java added
raft/src/main/java/org/apache/kafka/raft/LogAppendInfo.java added
raft/src/main/java/org/apache/kafka/raft/LogFetchInfo.java added
raft/src/main/java/org/apache/kafka/raft/LogOffsetMetadata.java added
raft/src/main/java/org/apache/kafka/raft/LogTruncationException.java added
raft/src/main/java/org/apache/kafka/raft/NetworkChannel.java added
raft/src/main/java/org/apache/kafka/raft/OffsetAndEpoch.java added
raft/src/main/java/org/apache/kafka/raft/OffsetMetadata.java added
raft/src/main/java/org/apache/kafka/raft/QuorumState.java added
raft/src/main/java/org/apache/kafka/raft/QuorumStateStore.java added
raft/src/main/java/org/apache/kafka/raft/RaftClient.java added
raft/src/main/java/org/apache/kafka/raft/RaftConfig.java added
raft/src/main/java/org/apache/kafka/raft/RaftMessage.java added
raft/src/main/java/org/apache/kafka/raft/RaftRequest.java added
raft/src/main/java/org/apache/kafka/raft/RaftResponse.java added
raft/src/main/java/org/apache/kafka/raft/RaftUtil.java added
raft/src/main/java/org/apache/kafka/raft/ReplicatedCounter.java added
raft/src/main/java/org/apache/kafka/raft/ReplicatedLog.java added
raft/src/main/java/org/apache/kafka/raft/RequestManager.java added
raft/src/main/java/org/apache/kafka/raft/UnattachedState.java added
raft/src/main/java/org/apache/kafka/raft/VotedState.java added
raft/src/test/java/org/apache/kafka/raft/CandidateStateTest.java added
raft/src/test/java/org/apache/kafka/raft/FileBasedStateStoreTest.java added
raft/src/test/java/org/apache/kafka/raft/FollowerStateTest.java added
raft/src/test/java/org/apache/kafka/raft/internals/KafkaRaftMetricsTest.java added
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java added
raft/src/test/java/org/apache/kafka/raft/LeaderStateTest.java added
raft/src/test/java/org/apache/kafka/raft/MockFuturePurgatory.java added
raft/src/test/java/org/apache/kafka/raft/MockFuturePurgatoryTest.java added
raft/src/test/java/org/apache/kafka/raft/MockLog.java added
raft/src/test/java/org/apache/kafka/raft/MockLogTest.java added
raft/src/test/java/org/apache/kafka/raft/MockNetworkChannel.java added
raft/src/test/java/org/apache/kafka/raft/MockQuorumStateStore.java added
raft/src/test/java/org/apache/kafka/raft/QuorumStateTest.java added
raft/src/test/java/org/apache/kafka/raft/RaftConfigTest.java added
raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java added
raft/src/test/java/org/apache/kafka/raft/RequestManagerTest.java added
raft/src/test/java/org/apache/kafka/raft/VotedStateTest.java added
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java changed 0.3% diff
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java changed 26.4% diff
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.j
ava
changed 33.9% diff
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo
.java
changed 14.5% diff
streams/examples/src/test/java/org/apache/kafka/streams/examples/docs/DeveloperGuideTesting.java changed 18.5% diff
streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountDemoTest.java changed 22.9% diff
streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorTest.j
ava
changed 39.7% diff
streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerTest
.java
changed 11.5% diff
streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStoreException.java changed 29.3% diff
streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStorePartitionException.java added
streams/src/main/java/org/apache/kafka/streams/errors/MissingSourceTopicException.java added
streams/src/main/java/org/apache/kafka/streams/errors/StateStoreMigratedException.java added
streams/src/main/java/org/apache/kafka/streams/errors/StateStoreNotAvailableException.java added
streams/src/main/java/org/apache/kafka/streams/errors/StreamsNotStartedException.java added
streams/src/main/java/org/apache/kafka/streams/errors/StreamsRebalancingException.java added
streams/src/main/java/org/apache/kafka/streams/errors/UnknownStateStoreException.java added
streams/src/main/java/org/apache/kafka/streams/internals/QuietStreamsConfig.java removed
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java changed 2.9% diff
streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java changed 29.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/CogroupedKStream.java changed 3.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java changed 3.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedKStreamImpl.java changed 9.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.ja
va
changed 94.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ConsumedInternal.java changed 6.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper
Serde.java
changed 11.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseJoinProcessorNode.java changed 20.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseRepartitionNode.java changed 6.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GlobalStoreNode.java changed 15.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GraphGraceSearchUtil.java changed 14.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GroupedTableOperationReparti
tionNode.java
changed 2.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableJoinNode.java changed 16.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.j
ava
changed 2.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorGraphNode.java changed 15.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorParameters.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java changed 21.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamStreamJoinNode.java changed 20.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamTableJoinNode.java changed 12.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamToTableNode.java changed 8.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableProcessorNode.java changed 13.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java changed 13.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode
.java
changed 2.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java changed 1.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java changed 7.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java changed 8.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java changed 1.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java changed 3.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatTransformValues.java changed 7.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java changed 4.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java changed 8.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java changed 5.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoin.java changed 18.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java changed 16.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPrint.java changed 3.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java changed 1.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java changed 0.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValues.java changed 7.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java changed 0.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java changed 3.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java changed 17.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java changed 4.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoin.java changed 13.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java changed 4.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMapValues.java changed 14.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMaterializedValueGetterSuppl
ier.java
changed 2.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableProcessorSupplier.java changed 75.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java changed 3.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMap.java changed 1.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSourceValueGetterSupplier.ja
va
changed 3.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableTransformValues.java changed 4.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetter.java changed 2.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/MaterializedInternal.java changed 6.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImp
l.java
changed 16.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java changed 2.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImp
l.java
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorSu
pplier.java
changed 4.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/SuppressedInternal.java changed 2.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/TimeDefinitions.java changed 12.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.j
ava
changed 17.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java changed 13.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableSerde.java added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableUtils.java added
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java changed 4.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java changed 2.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java changed 0.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.java changed 1.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedKStream.java changed 0.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/SlidingWindows.java added
streams/src/main/java/org/apache/kafka/streams/kstream/Suppressed.java changed 1.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java changed 2.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java changed 2.3% diff
streams/src/main/java/org/apache/kafka/streams/LagInfo.java changed 4.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/AbstractProcessor.java changed 4.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/api/Processor.java added
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java added
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorSupplier.java added
streams/src/main/java/org/apache/kafka/streams/processor/api/Record.java added
streams/src/main/java/org/apache/kafka/streams/processor/api/RecordMetadata.java added
streams/src/main/java/org/apache/kafka/streams/processor/ConnectedStoreProvider.java changed 2.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java changed 38.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java changed 21.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java changed 21.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java changed 0.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration
.java
changed 1.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorError.java changed 32.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java changed 22.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StreamsAssignmentProt
ocolVersions.java
changed 5.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java changed 1.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java changed 8.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorConte
xt.java
changed 1.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java changed 25.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java changed 45.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java changed 10.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java changed 5.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java changed 10.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java changed 33.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java changed 9.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.jav
a
changed 6.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java changed 13.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java changed 10.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java changed 0.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorAdapter.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java changed 31.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java changed 33.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNodePunctuator.java changed 10.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java changed 1.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java changed 15.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java changed 37.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java changed 1.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java changed 6.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java changed 2.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java changed 46.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java changed 35.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java changed 16.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java changed 20.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManager.java changed 9.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java changed 22.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreToProcessorContextAdapter.j
ava
added
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java changed 4.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java changed 8.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java changed 4.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListener.java changed 26.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java changed 15.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java changed 10.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java changed 7.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java changed 22.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ToInternal.java changed 5.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java changed 3.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java changed 50.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/StateStoreContext.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractMergedSortedCacheStoreIterat
or.java
changed 40.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.j
ava
changed 33.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractSegments.java changed 12.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/BlockBasedTableConfigWithAccessibleC
ache.java
added
streams/src/main/java/org/apache/kafka/streams/state/internals/CachedStateStore.java changed 17.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java changed 27.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java changed 44.9% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java changed 60.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStore.java changed 25.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java changed 49.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java changed 37.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeKeyValueIterator.java changed 4.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStore.java changed 47.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStore.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java changed 67.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java changed 28.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java changed 45.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.ja
va
changed 4.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java changed 38.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegment.java changed 8.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegments.java changed 21.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilder.java changed 7.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueToTimestampedKeyValueByteSto
reAdapter.java
changed 14.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java changed 18.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java changed 41.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheKeyValueBytesStoreI
terator.java
changed 17.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheSessionStoreIterato
r.java
changed 7.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreIterator
.java
changed 8.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreKeyValue
Iterator.java
changed 5.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java changed 42.9% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java changed 65.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java changed 14.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStore.java changed 24.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java changed 67.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java changed 74.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java changed 8.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java changed 6.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/OffsetCheckpoint.java changed 2.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/QueryableStoreProvider.java changed 25.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ReadOnlyKeyValueStoreFacade.java changed 18.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ReadOnlyWindowStoreFacade.java changed 50.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbIterator.java changed 12.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBPrefixIterator.java removed
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBRangeIterator.java changed 49.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStore.java changed 49.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java changed 20.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java changed 23.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbWindowBytesStoreSupplier.java changed 13.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java changed 54.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java changed 14.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedBytesStore.java changed 21.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java changed 19.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/Segments.java changed 29.9% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionKeySchema.java changed 3.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionStoreBuilder.java changed 9.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java changed 44.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java changed 9.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilder.java changed 13.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegment.java changed 8.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegments.java changed 21.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java changed 30.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampDeserializer.java changed 23.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerde.java changed 57.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerializer.java changed 50.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java changed 2.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreBuilder.java changed 7.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowToTimestampedWindowByteStoreAd
apter.java
changed 70.9% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedStateStore.java changed 13.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappingStoreProvider.java changed 29.1% diff
streams/src/main/java/org/apache/kafka/streams/state/KeyValueStore.java changed 4.1% diff
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java changed 4.8% diff
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java changed 70.6% diff
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java changed 48.4% diff
streams/src/main/java/org/apache/kafka/streams/state/Stores.java changed 1.6% diff
streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java changed 65.7% diff
streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java changed 15.8% diff
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java changed 6.2% diff
streams/src/main/java/org/apache/kafka/streams/Topology.java changed 17.1% diff
streams/src/main/java/org/apache/kafka/streams/TopologyDescription.java changed 4.9% diff
streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java changed 5.2% diff
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java changed 42.7% diff
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java changed 25.3% diff
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableIntegrationTest.java changed 4.5% diff
streams/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java changed 1.4% diff
streams/src/test/java/org/apache/kafka/streams/integration/HighAvailabilityTaskAssignorIntegrationT
est.java
changed 2.3% diff
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java changed 3.2% diff
streams/src/test/java/org/apache/kafka/streams/integration/JoinStoreIntegrationTest.java added
streams/src/test/java/org/apache/kafka/streams/integration/JoinWithIncompleteMetadataIntegrationTes
t.java
added
streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java changed 35.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/KStreamRepartitionIntegrationTest.java changed 0.3% diff
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiInte
grationTest.java
changed 2.4% diff
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinDistributedTes
t.java
added
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTes
t.java
changed 0.3% diff
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinMaterializatio
nIntegrationTest.java
changed 5.4% diff
streams/src/test/java/org/apache/kafka/streams/integration/LagFetchIntegrationTest.java changed 0.5% diff
streams/src/test/java/org/apache/kafka/streams/integration/MetricsIntegrationTest.java changed 3.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/OptimizedKTableIntegrationTest.java changed 7.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/PurgeRepartitionTopicIntegrationTest.jav
a
changed 6.8% diff
streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java changed 11.4% diff
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java changed 29.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationWithSslTest.java changed 21.2% diff
streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java changed 1.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/RocksDBMetricsIntegrationTest.java changed 28.0% diff
streams/src/test/java/org/apache/kafka/streams/integration/SmokeTestDriverIntegrationTest.java changed 7.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskCreationIntegrationTest.java changed 2.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskEOSIntegrationTest.java changed 3.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/StoreQueryIntegrationTest.java changed 46.8% diff
streams/src/test/java/org/apache/kafka/streams/integration/StreamStreamJoinIntegrationTest.java changed 9.2% diff
streams/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinIntegrationTest.java changed 30.9% diff
streams/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinTopologyOptimizationInteg
rationTest.java
added
streams/src/test/java/org/apache/kafka/streams/integration/SuppressionIntegrationTest.java changed 0.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/TaskAssignorIntegrationTest.java changed 1.4% diff
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java changed 2.0% diff
streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java changed 3.7% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/AbstractStreamTest.java changed 3.7% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/CogroupedKStreamImplTest.java changed 3.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResolve
rJoinProcessorSupplierTest.java
changed 0.6% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/GlobalKTableJoinsTest.java changed 2.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphTest.java changed 1.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNodeTest.java added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImplTest.java changed 49.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImplTest.java changed 2.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamBranchTest.java changed 5.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFilterTest.java changed 3.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapTest.java changed 4.5% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapValuesTest.java changed 3.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableJoinTest.java changed 13.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableLeftJoinTest.ja
va
changed 14.6% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java changed 0.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java changed 0.2% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinTest.java changed 2.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamMapTest.java changed 4.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamMapValuesTest.java changed 4.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSelectKeyTest.java changed 4.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregateProce
ssorTest.java
changed 1.5% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.
java
added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamTransformTest.java changed 12.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValuesTest.java changed 2.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregateTest.java changed 0.2% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableAggregateTest.java changed 6.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableFilterTest.java changed 20.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableImplTest.java changed 25.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableForeignKeyJoinScenario
Test.java
changed 1.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoinTest.java changed 3.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoinTest.java changed 2.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoinTest.java changed 2.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableMapKeysTest.java changed 4.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableMapValuesTest.java changed 21.6% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableSourceTest.java changed 4.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableTransformValuesTest.java changed 5.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImplTest.jav
a
changed 1.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImp
lTest.java
added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImplTest.jav
a
added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorMe
tricsTest.java
changed 0.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorTe
st.java
changed 0.6% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SuppressScenarioTest.java changed 16.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImplTest.java changed 4.6% diff
streams/src/test/java/org/apache/kafka/streams/kstream/RepartitionTopicNamingTest.java changed 0.7% diff
streams/src/test/java/org/apache/kafka/streams/kstream/SessionWindowsTest.java changed 6.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/SlidingWindowsTest.java added
streams/src/test/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContextTest.jav
a
changed 17.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreatorTest.java changed 0.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentTestUtils.j
ava
changed 22.2% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ClientStateTest.java changed 19.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfoTest.
java
changed 11.3% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImplTest.j
ava
changed 10.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java changed 94.9% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateTaskTest.java changed 9.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStreamThreadTest.java changed 8.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/HandlingSourceTopicDeletionInteg
rationTest.java
added
streams/src/test/java/org/apache/kafka/streams/processor/internals/HighAvailabilityStreamsPartition
AssignorTest.java
changed 2.4% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicManagerTest.java changed 51.4% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java changed 9.9% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImplTest.j
ava
changed 41.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetricsTest.java changed 0.2% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/MockStreamsMetrics.java changed 10.4% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java changed 6.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorNodeTest.java changed 9.3% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java changed 17.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyFactories.java changed 8.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java changed 20.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/PunctuationQueueTest.java changed 22.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java changed 5.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordDeserializerTest.java changed 2.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordQueueTest.java changed 0.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionOptimizingTest.java changed 0.4% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionWithMergeOptimizingTe
st.java
changed 0.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/SinkNodeTest.java changed 12.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/SourceNodeTest.java changed 8.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java changed 11.2% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java changed 15.3% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerStub.java changed 12.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsAssignmentScaleTest.java added
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsMetadataStateTest.java changed 1.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.jav
a
changed 13.2% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsProducerTest.java changed 6.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListenerTest.jav
a
added
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java changed 21.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java changed 5.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java changed 4.2% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/testutil/ConsumerRecordUtil.java added
streams/src/test/java/org/apache/kafka/streams/processor/internals/TimestampedKeyValueStoreMaterial
izerTest.java
changed 1.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractKeyValueStoreTest.java changed 44.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStoreTe
st.java
changed 2.1% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractSessionBytesStoreTest.java changed 41.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractWindowBytesStoreTest.java changed 16.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/BlockBasedTableConfigWithAccessibleC
acheTest.java
added
streams/src/test/java/org/apache/kafka/streams/state/internals/CacheFlushListenerStub.java added
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingKeyValueStoreTest.java renamed 30.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingInMemoryKeyValueStoreTest.java
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingPersistentSessionStoreTest.ja
va
added
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingSessionStoreTest.java renamed 47.1% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingInMemorySessionStoreTest.java
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingWindowStoreTest.java renamed 38.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingPersistentWindowStoreTest.java
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStoreTest.
java
changed 27.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStoreTest.j
ava
changed 42.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedKeyValueByte
sStoreTest.java
changed 22.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedWindowBytesS
toreTest.java
changed 18.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStoreTest.ja
va
changed 35.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStoreTest.j
ava
changed 43.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStoreTest.jav
a
changed 92.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/DelegatingPeekingKeyValueIteratorTes
t.java
changed 15.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/FilteredCacheIteratorTest.java changed 2.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/GlobalStateStoreProviderTest.java changed 33.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueLoggedStoreTest.java changed 8.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStoreTest.java changed 12.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryLRUCacheStoreTest.java changed 2.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryWindowStoreTest.java changed 7.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueSegmentsTest.java changed 13.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueSegmentTest.java changed 13.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilderTest.java changed 12.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheKeyValueBytesStoreI
teratorTest.java
changed 45.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedSessionStore
IteratorTest.java
changed 64.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedWindowStoreI
teratorTest.java
changed 80.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedWindowStoreK
eyValueIteratorTest.java
changed 53.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStoreTest.java changed 45.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredSessionStoreTest.java changed 75.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStoreTest.
java
changed 48.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStoreTest.ja
va
changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreTest.java changed 36.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderGauges
Test.java
added
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderTest.j
ava
changed 91.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsTest.java changed 81.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetricsTest.java changed 10.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/OffsetCheckpointTest.java changed 22.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/QueryableStoreProviderTest.java changed 12.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ReadOnlyWindowStoreStub.java changed 80.1% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBKeyValueStoreTest.java changed 18.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java changed 42.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStoreTest.java changed 22.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreTest.java changed 1.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/SegmentIteratorTest.java changed 46.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionStoreBuilderTest.java changed 12.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProviderTest.j
ava
changed 15.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ThreadCacheTest.java changed 1.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferTest.java changed 2.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilderTest.
java
changed 17.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedSegmentsTest.java changed 13.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedSegmentTest.java changed 13.1% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilderTest.ja
va
changed 19.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerializerTest.java changed 6.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowKeySchemaTest.java changed 25.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowStoreBuilderTest.java changed 14.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/WrappingStoreProviderTest.java changed 45.1% diff
streams/src/test/java/org/apache/kafka/streams/state/KeyValueStoreTestDriver.java changed 1.4% diff
streams/src/test/java/org/apache/kafka/streams/state/NoOpWindowStore.java changed 50.0% diff
streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java changed 24.2% diff
streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java changed 3.4% diff
streams/src/test/java/org/apache/kafka/streams/tests/BrokerCompatibilityTest.java changed 1.2% diff
streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java changed 3.5% diff
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java changed 28.0% diff
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java changed 1.8% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsBrokerDownResilienceTest.java changed 2.4% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsEosTest.java changed 5.4% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java changed 2.9% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsStandByReplicaTest.java changed 1.8% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java changed 1.5% diff
streams/src/test/java/org/apache/kafka/streams/tools/StreamsResetterTest.java changed 12.5% diff
streams/src/test/java/org/apache/kafka/streams/TopologyTest.java changed 3.7% diff
streams/src/test/java/org/apache/kafka/streams/TopologyTestDriverWrapper.java changed 8.9% diff
streams/src/test/java/org/apache/kafka/test/GenericInMemoryKeyValueStore.java changed 0.3% diff
streams/src/test/java/org/apache/kafka/test/GenericInMemoryTimestampedKeyValueStore.java changed 0.3% diff
streams/src/test/java/org/apache/kafka/test/GlobalStateManagerStub.java changed 9.7% diff
streams/src/test/java/org/apache/kafka/test/InternalMockProcessorContext.java changed 24.8% diff
streams/src/test/java/org/apache/kafka/test/MockApiProcessor.java added
streams/src/test/java/org/apache/kafka/test/MockApiProcessorSupplier.java added
streams/src/test/java/org/apache/kafka/test/MockInternalProcessorContext.java changed 16.3% diff
streams/src/test/java/org/apache/kafka/test/MockInternalTopicManager.java changed 15.0% diff
streams/src/test/java/org/apache/kafka/test/MockKeyValueStore.java changed 0.4% diff
streams/src/test/java/org/apache/kafka/test/MockProcessor.java changed 59.7% diff
streams/src/test/java/org/apache/kafka/test/MockProcessorNode.java changed 20.7% diff
streams/src/test/java/org/apache/kafka/test/MockRocksDbConfigSetter.java added
streams/src/test/java/org/apache/kafka/test/MockSourceNode.java changed 26.5% diff
streams/src/test/java/org/apache/kafka/test/NoOpProcessorContext.java changed 21.4% diff
streams/src/test/java/org/apache/kafka/test/NoOpReadOnlyStore.java changed 2.3% diff
streams/src/test/java/org/apache/kafka/test/ReadOnlySessionStoreStub.java changed 72.9% diff
streams/src/test/java/org/apache/kafka/test/SegmentedBytesStoreStub.java removed
streams/src/test/java/org/apache/kafka/test/StateStoreProviderStub.java changed 0.9% diff
streams/src/test/java/org/apache/kafka/test/StreamsTestUtils.java changed 2.7% diff
streams/test-utils/src/main/java/org/apache/kafka/streams/internals/KeyValueStoreFacade.java changed 7.3% diff
streams/test-utils/src/main/java/org/apache/kafka/streams/internals/WindowStoreFacade.java changed 56.0% diff
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/api/MockProcessorContext.java added
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java changed 5.1% diff
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java changed 2.8% diff
streams/test-utils/src/test/java/org/apache/kafka/streams/internals/KeyValueStoreFacadeTest.java changed 9.6% diff
streams/test-utils/src/test/java/org/apache/kafka/streams/internals/WindowStoreFacadeTest.java changed 12.6% diff
streams/test-utils/src/test/java/org/apache/kafka/streams/MockProcessorContextTest.java changed 2.6% diff
streams/test-utils/src/test/java/org/apache/kafka/streams/test/MockProcessorContextAPITest.java added
streams/test-utils/src/test/java/org/apache/kafka/streams/test/MockProcessorContextStateStoreTest.j
ava
added
streams/test-utils/src/test/java/org/apache/kafka/streams/test/wordcount/WindowedWordCountProcessor
Supplier.java
added
streams/test-utils/src/test/java/org/apache/kafka/streams/test/wordcount/WindowedWordCountProcessor
Test.java
added
streams/test-utils/src/test/java/org/apache/kafka/streams/TestTopicsTest.java changed 2.5% diff
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java changed 11.9% diff
streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java added
streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java added
streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java added
streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java added
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java added
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java added
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java added
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java added
streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java added
streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java added
streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java added
streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java added
streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java added
streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java added
streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java added
streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java added
streams/upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java added
streams/upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java added
streams/upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java added
streams/upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java added
streams/upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
added
tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java changed 7.7% diff
tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java changed 0.1% diff
tools/src/main/java/org/apache/kafka/trogdor/common/WorkerUtils.java changed 1.0% diff
tools/src/main/java/org/apache/kafka/trogdor/coordinator/TaskManager.java changed 0.7% diff
tools/src/main/java/org/apache/kafka/trogdor/fault/Kibosh.java changed 2.4% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressWorker.java changed 2.8% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java changed 0.5% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java changed 0.3% diff
tools/src/test/java/org/apache/kafka/tools/PushHttpMetricsReporterTest.java changed 37.4% diff
tools/src/test/java/org/apache/kafka/trogdor/agent/AgentTest.java changed 6.9% diff
tools/src/test/java/org/apache/kafka/trogdor/basic/BasicPlatformTest.java changed 8.9% diff
tools/src/test/java/org/apache/kafka/trogdor/common/JsonSerializationTest.java changed 4.8% diff
tools/src/test/java/org/apache/kafka/trogdor/common/JsonUtilTest.java changed 32.3% diff
tools/src/test/java/org/apache/kafka/trogdor/common/StringExpanderTest.java changed 12.0% diff
tools/src/test/java/org/apache/kafka/trogdor/common/StringFormatterTest.java changed 13.8% diff
tools/src/test/java/org/apache/kafka/trogdor/common/TopologyTest.java changed 15.5% diff
tools/src/test/java/org/apache/kafka/trogdor/common/WorkerUtilsTest.java changed 5.3% diff
tools/src/test/java/org/apache/kafka/trogdor/coordinator/CoordinatorClientTest.java changed 9.8% diff
tools/src/test/java/org/apache/kafka/trogdor/coordinator/CoordinatorTest.java changed 3.5% diff
tools/src/test/java/org/apache/kafka/trogdor/rest/RestExceptionMapperTest.java changed 23.0% diff
tools/src/test/java/org/apache/kafka/trogdor/task/TaskSpecTest.java changed 20.8% diff
tools/src/test/java/org/apache/kafka/trogdor/workload/ConsumeBenchSpecTest.java changed 11.1% diff
tools/src/test/java/org/apache/kafka/trogdor/workload/ExternalCommandWorkerTest.java changed 3.8% diff
tools/src/test/java/org/apache/kafka/trogdor/workload/HistogramTest.java changed 37.0% diff
tools/src/test/java/org/apache/kafka/trogdor/workload/PayloadGeneratorTest.java changed 9.8% diff
tools/src/test/java/org/apache/kafka/trogdor/workload/ThrottleTest.java changed 34.0% diff
tools/src/test/java/org/apache/kafka/trogdor/workload/TimeIntervalTransactionsGeneratorTest.java changed 7.5% diff
tools/src/test/java/org/apache/kafka/trogdor/workload/TopicsSpecTest.java changed 9.0% diff

Python Programs (56 of 139):

NameStatusDeltaVisual Diff
kafka-merge-pr.py changed 0.4% diff
tests/kafkatest/__init__.py changed 1.8% diff
tests/kafkatest/benchmarks/core/benchmark_test.py changed 0.9% diff
tests/kafkatest/sanity_checks/test_console_consumer.py changed 0.9% diff
tests/kafkatest/sanity_checks/test_verifiable_producer.py changed 2.7% diff
tests/kafkatest/services/console_consumer.py changed 0.1% diff
tests/kafkatest/services/kafka/__init__.py changed 11.5% diff
tests/kafkatest/services/kafka/config.py changed 10.5% diff
tests/kafkatest/services/kafka/config_property.py changed 0.6% diff
tests/kafkatest/services/kafka/kafka.py changed 47.9% diff
tests/kafkatest/services/monitor/http.py changed 2.2% diff
tests/kafkatest/services/monitor/jmx.py changed 0.9% diff
tests/kafkatest/services/performance/__init__.py changed 26.4% diff
tests/kafkatest/services/performance/producer_performance.py changed 1.4% diff
tests/kafkatest/services/security/kafka_acls.py changed 100.0% diff
tests/kafkatest/services/security/minikdc.py changed 0.5% diff
tests/kafkatest/services/security/security_config.py changed 10.0% diff
tests/kafkatest/services/streams.py changed 9.2% diff
tests/kafkatest/services/trogdor/task_spec.py changed 2.6% diff
tests/kafkatest/services/verifiable_client.py changed 0.1% diff
tests/kafkatest/services/verifiable_consumer.py changed 4.9% diff
tests/kafkatest/services/zookeeper.py changed 0.1% diff
tests/kafkatest/tests/client/client_compatibility_features_test.py changed 5.9% diff
tests/kafkatest/tests/client/quota_test.py changed 2.8% diff
tests/kafkatest/tests/connect/connect_distributed_test.py changed 3.3% diff
tests/kafkatest/tests/connect/connect_test.py changed 1.2% diff
tests/kafkatest/tests/core/downgrade_test.py changed 7.8% diff
tests/kafkatest/tests/core/get_offset_shell_test.py changed 1.9% diff
tests/kafkatest/tests/core/group_mode_transactions_test.py changed 5.7% diff
tests/kafkatest/tests/core/mirror_maker_test.py changed 0.5% diff
tests/kafkatest/tests/core/network_degrade_test.py changed 0.7% diff
tests/kafkatest/tests/core/reassign_partitions_test.py changed 0.8% diff
tests/kafkatest/tests/core/replica_scale_test.py changed 3.0% diff
tests/kafkatest/tests/core/security_rolling_upgrade_test.py changed 3.1% diff
tests/kafkatest/tests/core/security_test.py changed 8.0% diff
tests/kafkatest/tests/core/throttling_test.py changed 1.1% diff
tests/kafkatest/tests/core/transactions_test.py changed 0.5% diff
tests/kafkatest/tests/core/upgrade_test.py changed 0.7% diff
tests/kafkatest/tests/core/zookeeper_security_upgrade_test.py changed 7.4% diff
tests/kafkatest/tests/core/zookeeper_tls_encrypt_only_test.py changed 7.1% diff
tests/kafkatest/tests/core/zookeeper_tls_test.py changed 0.9% diff
tests/kafkatest/tests/end_to_end.py changed 1.3% diff
tests/kafkatest/tests/streams/streams_application_upgrade_test.py added
tests/kafkatest/tests/streams/streams_broker_bounce_test.py changed 4.7% diff
tests/kafkatest/tests/streams/streams_broker_compatibility_test.py changed 1.8% diff
tests/kafkatest/tests/streams/streams_cooperative_rebalance_upgrade_test.py changed 1.1% diff
tests/kafkatest/tests/streams/streams_static_membership_test.py changed 4.4% diff
tests/kafkatest/tests/streams/streams_upgrade_test.py changed 15.8% diff
tests/kafkatest/tests/streams/utils/__init__.py changed 13.8% diff
tests/kafkatest/tests/streams/utils/util.py changed 18.6% diff
tests/kafkatest/tests/tools/log4j_appender_test.py changed 1.8% diff
tests/kafkatest/tests/verifiable_consumer_test.py changed 1.0% diff
tests/kafkatest/utils/__init__.py changed 13.0% diff
tests/kafkatest/utils/util.py changed 0.3% diff
tests/kafkatest/version.py changed 26.7% diff
tests/setup.py changed 3.2% diff

Shell Programs (7 of 48):

NameStatusDeltaVisual Diff
bin/kafka-features.sh added
bin/kafka-run-class.sh changed 1.3% diff
bin/kafka-server-stop.sh changed 22.6% diff
bin/zookeeper-server-stop.sh changed 15.2% diff
raft/bin/test-raft-server-start.sh added
tests/docker/ducker-ak changed 1.3% diff
vagrant/base.sh changed 5.8% diff

Configuration Files (1 of 8):

NameStatusDeltaVisual Diff
tests/kafkatest/services/security/templates/admin_client_as_broker_jaas.conf added

JavaScript Files (all 1):

NameStatusDeltaVisual Diff
docs/js/templateData.js changed 8.8% diff

JSON Files (42 of 131):

NameStatusDeltaVisual Diff
clients/src/main/resources/common/message/AddOffsetsToTxnRequest.json changed 6.3% diff
clients/src/main/resources/common/message/AddOffsetsToTxnResponse.json changed 7.2% diff
clients/src/main/resources/common/message/AddPartitionsToTxnRequest.json changed 5.3% diff
clients/src/main/resources/common/message/AddPartitionsToTxnResponse.json changed 5.1% diff
clients/src/main/resources/common/message/AlterIsrRequest.json added
clients/src/main/resources/common/message/AlterIsrResponse.json added
clients/src/main/resources/common/message/AlterUserScramCredentialsRequest.json added
clients/src/main/resources/common/message/AlterUserScramCredentialsResponse.json added
clients/src/main/resources/common/message/ApiVersionsResponse.json changed 76.9% diff
clients/src/main/resources/common/message/BeginQuorumEpochRequest.json added
clients/src/main/resources/common/message/BeginQuorumEpochResponse.json added
clients/src/main/resources/common/message/ConsumerProtocolAssignment.json added
clients/src/main/resources/common/message/ConsumerProtocolSubscription.json added
clients/src/main/resources/common/message/CreatePartitionsRequest.json changed 14.6% diff
clients/src/main/resources/common/message/CreatePartitionsResponse.json changed 10.4% diff
clients/src/main/resources/common/message/CreateTopicsRequest.json changed 5.8% diff
clients/src/main/resources/common/message/CreateTopicsResponse.json changed 5.2% diff
clients/src/main/resources/common/message/DeleteTopicsRequest.json changed 14.9% diff
clients/src/main/resources/common/message/DeleteTopicsResponse.json changed 25.0% diff
clients/src/main/resources/common/message/DescribeQuorumRequest.json added
clients/src/main/resources/common/message/DescribeQuorumResponse.json added
clients/src/main/resources/common/message/DescribeUserScramCredentialsRequest.json added
clients/src/main/resources/common/message/DescribeUserScramCredentialsResponse.json added
clients/src/main/resources/common/message/EndQuorumEpochRequest.json added
clients/src/main/resources/common/message/EndQuorumEpochResponse.json added
clients/src/main/resources/common/message/EndTxnRequest.json changed 6.6% diff
clients/src/main/resources/common/message/EndTxnResponse.json changed 7.3% diff
clients/src/main/resources/common/message/FetchRequest.json changed 34.2% diff
clients/src/main/resources/common/message/FetchResponse.json changed 48.1% diff
clients/src/main/resources/common/message/InitProducerIdRequest.json changed 4.9% diff
clients/src/main/resources/common/message/InitProducerIdResponse.json changed 5.6% diff
clients/src/main/resources/common/message/LeaderChangeMessage.json added
clients/src/main/resources/common/message/ListOffsetRequest.json changed 6.7% diff
clients/src/main/resources/common/message/ListOffsetResponse.json changed 3.1% diff
clients/src/main/resources/common/message/UpdateFeaturesRequest.json added
clients/src/main/resources/common/message/UpdateFeaturesResponse.json added
clients/src/main/resources/common/message/VoteRequest.json added
clients/src/main/resources/common/message/VoteResponse.json added
clients/src/test/resources/common/message/SimpleExampleMessage.json changed 19.0% diff
clients/src/test/resources/common/message/SimpleRecordsMessage.json added
raft/src/main/resources/common/message/QuorumState.json added
streams/src/main/resources/common/message/SubscriptionInfoData.json changed 4.5% diff

XML Documents (8 of 10):

NameStatusDeltaVisual Diff
checkstyle/checkstyle.xml changed 7.6% diff
checkstyle/import-control-jmh-benchmarks.xml changed 2.2% diff
checkstyle/import-control.xml changed 6.4% diff
checkstyle/suppressions.xml changed 36.7% diff
gradle/spotbugs-exclude.xml changed 4.8% diff
streams/quickstart/java/pom.xml changed 2.4% diff
streams/quickstart/java/src/main/resources/archetype-resources/pom.xml changed 0.8% diff
streams/quickstart/pom.xml changed 0.7% diff

DOS Batch Files (1 of 27):

NameStatusDeltaVisual Diff
bin/windows/kafka-run-class.bat changed 0.5% diff

Git Files (1 of 8):

NameStatusDeltaVisual Diff
.gitignore changed 3.1% diff

HTML Pages (36 of 63):

NameStatusDeltaVisual Diff
docs/api.html changed 6.7%
docs/configuration.html changed 4.9%
docs/design.html changed 2.3%
docs/documentation.html changed 18.3%
docs/documentation/streams/developer-guide/dsl-topology-naming.html changed 1.9%
docs/implementation.html changed 5.5%
docs/introduction.html changed 28.4%
docs/migration.html changed 5.5%
docs/ops.html changed 3.2%
docs/protocol.html changed 4.4%
docs/quickstart-zookeeper.html added
docs/quickstart.html renamed 24.5%
docs/quickstart-docker.html
docs/security.html changed 5.0%
docs/streams/architecture.html changed 3.5%
docs/streams/core-concepts.html changed 10.8%
docs/streams/developer-guide/app-reset-tool.html changed 0.04%
docs/streams/developer-guide/config-streams.html changed 12.7%
docs/streams/developer-guide/datatypes.html changed 0.005%
docs/streams/developer-guide/dsl-api.html changed 2.0%
docs/streams/developer-guide/dsl-topology-naming.html changed 3.0%
docs/streams/developer-guide/index.html changed 0.02%
docs/streams/developer-guide/interactive-queries.html changed 0.2%
docs/streams/developer-guide/manage-topics.html changed 0.01%
docs/streams/developer-guide/memory-mgmt.html changed 2.0%
docs/streams/developer-guide/processor-api.html changed 0.1%
docs/streams/developer-guide/running-app.html changed 9.4%
docs/streams/developer-guide/security.html changed 0.1%
docs/streams/developer-guide/testing.html changed 3.4%
docs/streams/developer-guide/write-streams.html changed 0.2%
docs/streams/index.html changed 0.3%
docs/streams/quickstart.html changed 3.2%
docs/streams/tutorial.html changed 2.9%
docs/streams/upgrade-guide.html changed 6.2%
docs/upgrade.html changed 11.0%
docs/uses.html changed 6.2%

Log Files (16 of 36):

NameStatusDeltaVisual Diff
core/src/main/scala/kafka/log/Log.scala changed 5.0% diff
core/src/main/scala/kafka/log/LogCleaner.scala changed 1.1% diff
core/src/main/scala/kafka/log/LogCleanerManager.scala changed 8.9% diff
core/src/main/scala/kafka/log/LogConfig.scala changed 0.4% diff
core/src/main/scala/kafka/log/LogManager.scala changed 22.0% diff
core/src/main/scala/kafka/log/LogSegment.scala changed 1.3% diff
core/src/main/scala/kafka/log/LogValidator.scala changed 1.6% diff
core/src/main/scala/kafka/log/ProducerStateManager.scala changed 1.0% diff
core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala changed 17.8% diff
core/src/test/scala/unit/kafka/log/LogCleanerParameterizedIntegrationTest.scala changed 0.6% diff
core/src/test/scala/unit/kafka/log/LogCleanerTest.scala changed 0.1% diff
core/src/test/scala/unit/kafka/log/LogConfigTest.scala changed 4.4% diff
core/src/test/scala/unit/kafka/log/LogManagerTest.scala changed 14.5% diff
core/src/test/scala/unit/kafka/log/LogSegmentTest.scala changed 12.3% diff
core/src/test/scala/unit/kafka/log/LogTest.scala changed 0.8% diff
core/src/test/scala/unit/kafka/log/ProducerStateManagerTest.scala changed 0.4% diff

Property Files (9 of 50):

NameStatusDeltaVisual Diff
gradle.properties changed 3.2% diff
gradle/wrapper/gradle-wrapper.properties changed 40.0% diff
raft/config/raft-log4j.properties added
raft/config/raft.properties added
raft/src/test/resources/log4j.properties added
streams/src/test/resources/log4j.properties changed 18.3% diff
tests/kafkatest/services/kafka/templates/kafka.properties changed 4.1% diff
tests/kafkatest/services/templates/tools_log4j.properties changed 4.0% diff
tests/kafkatest/tests/streams/templates/log4j_template.properties changed 4.0% diff

YAML Files (1 of 2):

NameStatusDeltaVisual Diff
.asf.yaml changed 3.4% diff

Image Files (1 of 50):

NameStatusDeltaVisual Diff
docs/images/streams-sliding-windows.png added

Directories (43 of 859):

NameStatus
clients/src/main/java/org/apache/kafka/common/feature added
clients/src/test/java/org/apache/kafka/common/feature added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters added
core/src/main/scala/kafka/raft added
core/src/test/scala/unit/kafka/raft added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/consumer added
raft added
raft/bin added
raft/config added
raft/src added
raft/src/main added
raft/src/main/java added
raft/src/main/java/org added
raft/src/main/java/org/apache added
raft/src/main/java/org/apache/kafka added
raft/src/main/java/org/apache/kafka/raft added
raft/src/main/java/org/apache/kafka/raft/internals added
raft/src/main/resources added
raft/src/main/resources/common added
raft/src/main/resources/common/message added
raft/src/main/resources/common/META-INF added
raft/src/main/resources/common/META-INF/services added
raft/src/test added
raft/src/test/java added
raft/src/test/java/org added
raft/src/test/java/org/apache added
raft/src/test/java/org/apache/kafka added
raft/src/test/java/org/apache/kafka/raft added
raft/src/test/java/org/apache/kafka/raft/internals added
raft/src/test/resources added
streams/src/main/java/org/apache/kafka/streams/processor/api added
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/serialization added
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/api added
streams/test-utils/src/test/java/org/apache/kafka/streams/test/wordcount added
streams/upgrade-system-tests-26 added
streams/upgrade-system-tests-26/src added
streams/upgrade-system-tests-26/src/test added
streams/upgrade-system-tests-26/src/test/java added
streams/upgrade-system-tests-26/src/test/java/org added
streams/upgrade-system-tests-26/src/test/java/org/apache added
streams/upgrade-system-tests-26/src/test/java/org/apache/kafka added
streams/upgrade-system-tests-26/src/test/java/org/apache/kafka/streams added
streams/upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests added

Readme Files (4 of 8):

NameStatusDeltaVisual Diff
connect/mirror/README.md changed 33.0% diff
raft/README.md added
README.md changed 9.6% diff
tests/README.md changed 1.0% diff

Text Files (196 of 422):

NameStatusDeltaVisual Diff
build.gradle changed 15.3% diff
core/src/main/scala/kafka/api/ApiVersion.scala changed 6.4% diff
core/src/main/scala/kafka/api/LeaderAndIsr.scala changed 12.9% diff
core/src/main/scala/kafka/cluster/Broker.scala changed 21.3% diff
core/src/main/scala/kafka/cluster/Partition.scala changed 30.0% diff
core/src/main/scala/kafka/common/InterBrokerSendThread.scala changed 7.1% diff
core/src/main/scala/kafka/common/MessageFormatter.scala changed 24.0% diff
core/src/main/scala/kafka/controller/ControllerChannelManager.scala changed 3.2% diff
core/src/main/scala/kafka/controller/ControllerEventManager.scala changed 21.7% diff
core/src/main/scala/kafka/controller/ControllerState.scala changed 5.4% diff
core/src/main/scala/kafka/controller/KafkaController.scala changed 37.0% diff
core/src/main/scala/kafka/controller/PartitionStateMachine.scala changed 2.0% diff
core/src/main/scala/kafka/controller/ReplicaStateMachine.scala changed 2.2% diff
core/src/main/scala/kafka/controller/TopicDeletionManager.scala changed 0.6% diff
core/src/main/scala/kafka/coordinator/group/DelayedJoin.scala changed 13.7% diff
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala changed 7.3% diff
core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala changed 2.1% diff
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala changed 2.7% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala changed 0.8% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala changed 0.9% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala changed 1.0% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala changed 0.6% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala changed 0.3% diff
core/src/main/scala/kafka/Kafka.scala changed 2.3% diff
core/src/main/scala/kafka/network/SocketServer.scala changed 15.2% diff
core/src/main/scala/kafka/raft/KafkaFuturePurgatory.scala added
core/src/main/scala/kafka/raft/KafkaMetadataLog.scala added
core/src/main/scala/kafka/raft/KafkaNetworkChannel.scala added
core/src/main/scala/kafka/raft/SegmentPosition.scala added
core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala changed 7.5% diff
core/src/main/scala/kafka/server/AbstractFetcherManager.scala changed 2.0% diff
core/src/main/scala/kafka/server/AbstractFetcherThread.scala changed 1.7% diff
core/src/main/scala/kafka/server/ActionQueue.scala added
core/src/main/scala/kafka/server/AdminManager.scala changed 56.7% diff
core/src/main/scala/kafka/server/AlterIsrManager.scala added
core/src/main/scala/kafka/server/BrokerFeatures.scala added
core/src/main/scala/kafka/server/BrokerToControllerChannelManagerImpl.scala added
core/src/main/scala/kafka/server/checkpoints/LeaderEpochCheckpointFile.scala changed 23.9% diff
core/src/main/scala/kafka/server/checkpoints/OffsetCheckpointFile.scala changed 12.7% diff
core/src/main/scala/kafka/server/ClientQuotaManager.scala changed 22.5% diff
core/src/main/scala/kafka/server/ClientRequestQuotaManager.scala changed 36.2% diff
core/src/main/scala/kafka/server/ConfigHandler.scala changed 4.4% diff
core/src/main/scala/kafka/server/ControllerMutationQuotaManager.scala added
core/src/main/scala/kafka/server/DelayedCreatePartitions.scala changed 14.4% diff
core/src/main/scala/kafka/server/DelayedDeleteRecords.scala changed 4.3% diff
core/src/main/scala/kafka/server/DelayedDeleteTopics.scala changed 6.3% diff
core/src/main/scala/kafka/server/DelayedFetch.scala changed 19.0% diff
core/src/main/scala/kafka/server/DelayedOperation.scala changed 21.2% diff
core/src/main/scala/kafka/server/DelayedProduce.scala changed 4.6% diff
core/src/main/scala/kafka/server/DelegationTokenManager.scala changed 2.0% diff
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala changed 2.5% diff
core/src/main/scala/kafka/server/DynamicConfig.scala changed 21.6% diff
core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala changed 45.7% diff
core/src/main/scala/kafka/server/FetchSession.scala changed 2.3% diff
core/src/main/scala/kafka/server/FinalizedFeatureCache.scala added
core/src/main/scala/kafka/server/FinalizedFeatureChangeListener.scala added
core/src/main/scala/kafka/server/KafkaApis.scala changed 15.7% diff
core/src/main/scala/kafka/server/KafkaConfig.scala changed 4.6% diff
core/src/main/scala/kafka/server/KafkaRequestHandler.scala changed 1.9% diff
core/src/main/scala/kafka/server/KafkaServer.scala changed 5.7% diff
core/src/main/scala/kafka/server/MetadataCache.scala changed 2.1% diff
core/src/main/scala/kafka/server/QuotaFactory.scala changed 24.7% diff
core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala changed 2.1% diff
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala changed 6.5% diff
core/src/main/scala/kafka/server/ReplicaManager.scala changed 15.6% diff
core/src/main/scala/kafka/server/ReplicationQuotaManager.scala changed 2.3% diff
core/src/main/scala/kafka/server/SensorAccess.scala changed 12.3% diff
core/src/main/scala/kafka/tools/TestRaftRequestHandler.scala added
core/src/main/scala/kafka/tools/TestRaftServer.scala added
core/src/main/scala/kafka/utils/CommandLineUtils.scala changed 7.6% diff
core/src/main/scala/kafka/utils/CoreUtils.scala changed 3.9% diff
core/src/main/scala/kafka/utils/Implicits.scala changed 44.3% diff
core/src/main/scala/kafka/utils/json/DecodeJson.scala changed 0.7% diff
core/src/main/scala/kafka/utils/Log4jController.scala changed 5.5% diff
core/src/main/scala/kafka/utils/QuotaUtils.scala added
core/src/main/scala/kafka/utils/timer/Timer.scala changed 1.5% diff
core/src/main/scala/kafka/utils/timer/TimerTask.scala changed 5.7% diff
core/src/main/scala/kafka/utils/timer/TimerTaskList.scala changed 1.2% diff
core/src/main/scala/kafka/utils/TopicFilter.scala changed 4.1% diff
core/src/main/scala/kafka/zk/AdminZkClient.scala changed 21.1% diff
core/src/main/scala/kafka/zk/KafkaZkClient.scala changed 2.3% diff
core/src/main/scala/kafka/zk/ZkData.scala changed 22.6% diff
core/src/test/scala/integration/kafka/admin/BrokerApiVersionsCommandTest.scala changed 12.6% diff
core/src/test/scala/integration/kafka/admin/ReassignPartitionsIntegrationTest.scala changed 40.5% diff
core/src/test/scala/integration/kafka/api/AdminClientWithPoliciesIntegrationTest.scala changed 0.2% diff
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala changed 3.1% diff
core/src/test/scala/integration/kafka/api/BaseAdminIntegrationTest.scala changed 1.9% diff
core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala changed 9.5% diff
core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala changed 10.0% diff
core/src/test/scala/integration/kafka/api/ClientIdQuotaTest.scala changed 41.7% diff
core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala changed 5.9% diff
core/src/test/scala/integration/kafka/api/DelegationTokenEndToEndAuthorizationTest.scala changed 54.6% diff
core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala changed 4.8% diff
core/src/test/scala/integration/kafka/api/MetricsTest.scala changed 1.8% diff
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala changed 1.3% diff
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala changed 0.7% diff
core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala changed 9.1% diff
core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala changed 10.4% diff
core/src/test/scala/integration/kafka/api/SaslEndToEndAuthorizationTest.scala changed 1.0% diff
core/src/test/scala/integration/kafka/api/SaslScramSslEndToEndAuthorizationTest.scala changed 33.7% diff
core/src/test/scala/integration/kafka/api/SaslSetup.scala changed 31.4% diff
core/src/test/scala/integration/kafka/api/SaslSslAdminIntegrationTest.scala changed 1.6% diff
core/src/test/scala/integration/kafka/api/SslAdminIntegrationTest.scala changed 0.5% diff
core/src/test/scala/integration/kafka/api/TransactionsBounceTest.scala changed 0.7% diff
core/src/test/scala/integration/kafka/api/TransactionsTest.scala changed 5.2% diff
core/src/test/scala/integration/kafka/api/TransactionsWithMaxInFlightOneTest.scala added
core/src/test/scala/integration/kafka/api/UserClientIdQuotaTest.scala changed 44.0% diff
core/src/test/scala/integration/kafka/api/UserQuotaTest.scala changed 26.1% diff
core/src/test/scala/integration/kafka/network/DynamicConnectionQuotaTest.scala changed 58.2% diff
core/src/test/scala/integration/kafka/server/DelayedFetchTest.scala changed 46.7% diff
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala changed 1.2% diff
core/src/test/scala/integration/kafka/tools/MirrorMakerIntegrationTest.scala changed 9.2% diff
core/src/test/scala/kafka/security/minikdc/MiniKdc.scala changed 0.4% diff
core/src/test/scala/kafka/tools/DefaultMessageFormatterTest.scala added
core/src/test/scala/kafka/utils/LoggingTest.scala changed 17.2% diff
core/src/test/scala/unit/kafka/admin/ConfigCommandTest.scala changed 12.5% diff
core/src/test/scala/unit/kafka/admin/DelegationTokenCommandTest.scala changed 1.0% diff
core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala changed 4.1% diff
core/src/test/scala/unit/kafka/admin/FeatureCommandTest.scala added
core/src/test/scala/unit/kafka/admin/PreferredReplicaLeaderElectionCommandTest.scala changed 0.5% diff
core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala changed 11.2% diff
core/src/test/scala/unit/kafka/admin/TopicCommandWithZKClientTest.scala changed 0.2% diff
core/src/test/scala/unit/kafka/admin/UserScramCredentialsCommandTest.scala added
core/src/test/scala/unit/kafka/cluster/AssignmentStateTest.scala changed 1.5% diff
core/src/test/scala/unit/kafka/cluster/PartitionLockTest.scala changed 2.2% diff
core/src/test/scala/unit/kafka/cluster/PartitionTest.scala changed 18.8% diff
core/src/test/scala/unit/kafka/controller/ControllerFailoverTest.scala changed 1.1% diff
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala changed 35.2% diff
core/src/test/scala/unit/kafka/controller/MockPartitionStateMachine.scala changed 3.2% diff
core/src/test/scala/unit/kafka/coordinator/AbstractCoordinatorConcurrencyTest.scala changed 4.0% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorConcurrencyTest.scala changed 12.5% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorConcurrencyTest.scala changed 0.6% diff
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala changed 7.4% diff
core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala changed 0.3% diff
core/src/test/scala/unit/kafka/integration/MinIsrConfigTest.scala changed 6.4% diff
core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala changed 1.6% diff
core/src/test/scala/unit/kafka/metrics/MetricsTest.scala changed 2.1% diff
core/src/test/scala/unit/kafka/security/auth/SimpleAclAuthorizerTest.scala changed 0.1% diff
core/src/test/scala/unit/kafka/security/authorizer/AclAuthorizerTest.scala changed 0.2% diff
core/src/test/scala/unit/kafka/security/token/delegation/DelegationTokenManagerTest.scala changed 2.1% diff
core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala changed 6.4% diff
core/src/test/scala/unit/kafka/server/AlterReplicaLogDirsRequestTest.scala changed 37.4% diff
core/src/test/scala/unit/kafka/server/AlterUserScramCredentialsRequestTest.scala added
core/src/test/scala/unit/kafka/server/ClientQuotasRequestTest.scala changed 2.8% diff
core/src/test/scala/unit/kafka/server/ClientRequestQuotaManagerTest.scala added
core/src/test/scala/unit/kafka/server/ControllerMutationQuotaTest.scala added
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsOnPlainTextTest.scala changed 2.0% diff
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsTest.scala changed 1.1% diff
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsWithDisableTokenFeatureTest.scala changed 1.6% diff
core/src/test/scala/unit/kafka/server/DescribeLogDirsRequestTest.scala changed 33.1% diff
core/src/test/scala/unit/kafka/server/DescribeUserScramCredentialsRequestTest.scala added
core/src/test/scala/unit/kafka/server/DynamicConfigChangeTest.scala changed 11.7% diff
core/src/test/scala/unit/kafka/server/epoch/EpochDrivenReplicationProtocolAcceptanceTest.scala changed 1.8% diff
core/src/test/scala/unit/kafka/server/epoch/LeaderEpochIntegrationTest.scala changed 1.3% diff
core/src/test/scala/unit/kafka/server/FetchRequestTest.scala changed 6.8% diff
core/src/test/scala/unit/kafka/server/FinalizedFeatureChangeListenerTest.scala added
core/src/test/scala/unit/kafka/server/ListOffsetsRequestTest.scala changed 63.4% diff
core/src/test/scala/unit/kafka/server/LogDirFailureTest.scala changed 15.9% diff
core/src/test/scala/unit/kafka/server/LogOffsetTest.scala changed 21.9% diff
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala changed 11.9% diff
core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala changed 5.5% diff
core/src/test/scala/unit/kafka/server/ReplicationQuotasTest.scala changed 0.8% diff
core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala changed 9.7% diff
core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala changed 1.1% diff
core/src/test/scala/unit/kafka/server/UpdateFeaturesTest.scala added
core/src/test/scala/unit/kafka/utils/JaasTestUtils.scala changed 12.1% diff
core/src/test/scala/unit/kafka/utils/MockScheduler.scala changed 0.7% diff
core/src/test/scala/unit/kafka/utils/TestUtils.scala changed 4.5% diff
core/src/test/scala/unit/kafka/zk/AdminZkClientTest.scala changed 0.7% diff
core/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala changed 3.2% diff
gradle/dependencies.gradle changed 11.8% diff
gradlew changed 2.9% diff
Jenkinsfile added
raft/src/main/resources/common/META-INF/services/org.apache.kafka.common.config.provider.ConfigProv
ider
added
settings.gradle changed 3.1% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KGroupedStream.scala changed 2.8% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala changed 1.9% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/SessionWindowedKStream.
scala
changed 3.8% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/TimeWindowedKStream.sca
la
changed 4.0% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala changed 4.2% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/serialization/Serdes.scala added
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala changed 10.6% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/ConsumedTest.scala changed 21.5% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/GroupedTest.scala changed 20.5% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/JoinedTest.scala changed 27.6% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala changed 0.5% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KTableTest.scala changed 4.5% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/MaterializedTest.scala changed 22.2% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/ProducedTest.scala changed 19.0% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/RepartitionedTest.scala changed 21.6% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/StreamJoinedTest.scala changed 26.5% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinScalaIntegrati
onTestImplicitSerdes.scala
changed 13.6% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/utils/StreamToTableJoinScalaInt
egrationTestBase.scala
changed 1.6% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/utils/TestDriver.scala changed 12.1% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/WordCountTest.scala changed 5.9% diff
tests/docker/Dockerfile changed 15.1% diff

Packages Compared:

kafka-2.6.0-src.tgz
kafka-2.7.0-src.tgz


Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)