"Fossies" - the Fresh Open Source Software Archive  

Source code changes report for "kafka" between the packages
kafka-2.3.1-src.tgz and kafka-2.4.0-src.tgz

About: Apache kafka is a distributed streaming platform.

Summary:

The "kafka" source code changed by about 15.9% and now consists of 3422 regular files (+270) and 773 directories (+59).

Related Informations:

None found by Fossies.

Changes In Files (According File Type):

File TypeTotalAddedRemovedChanged
C program 124 4 1 94
Java program 2395 244 11 683
Python program 137 10 0 31
Shell program 46 3 0 4
Ruby program 1 0 0 0
Configuration file 7 0 0 0
JavaScript file 1 0 0 1
JSON file 107 9 2 90
XML document 10 1 0 6
DOS Batch file 27 2 0 1
Git file 8 0 0 1
HTML page 59 1 0 18
Property file 45 4 0 10
RDF file 1 0 0 0
XML style sheet 1 0 0 0
YAML file 1 0 0 0
Image file 49 0 0 0
Directory 773 59 0 0
Information file 3 0 0 0
License 1 0 0 0
Readme file 7 1 0 3
Text file 415 16 11 258
Other 2 0 0 0
Total Files4220354251200



C Programs (99 of 124):

NameStatusDeltaVisual Diff
core/src/main/scala/kafka/admin/AclCommand.scala changed 35.7% diff
core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala changed 100.0% diff
core/src/main/scala/kafka/admin/ConfigCommand.scala changed 26.3% diff
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala changed 12.2% diff
core/src/main/scala/kafka/admin/DelegationTokenCommand.scala changed 6.2% diff
core/src/main/scala/kafka/admin/DeleteRecordsCommand.scala changed 1.9% diff
core/src/main/scala/kafka/admin/LeaderElectionCommand.scala added
core/src/main/scala/kafka/admin/LogDirsCommand.scala changed 4.9% diff
core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala changed 23.4% diff
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala changed 3.6% diff
core/src/main/scala/kafka/admin/TopicCommand.scala changed 26.0% diff
core/src/main/scala/kafka/admin/ZkSecurityMigrator.scala changed 5.3% diff
core/src/main/scala/kafka/common/ZkNodeChangeNotificationListener.scala changed 4.2% diff
core/src/main/scala/kafka/controller/ControllerContext.scala changed 28.0% diff
core/src/main/scala/kafka/Kafka.scala changed 2.5% diff
core/src/main/scala/kafka/log/LogConfig.scala changed 4.5% diff
core/src/main/scala/kafka/network/RequestChannel.scala changed 2.1% diff
core/src/main/scala/kafka/tools/ConsoleConsumer.scala changed 4.4% diff
core/src/main/scala/kafka/tools/ConsoleProducer.scala changed 0.9% diff
core/src/main/scala/kafka/tools/ConsumerPerformance.scala changed 1.7% diff
core/src/main/scala/kafka/tools/DumpLogSegments.scala changed 3.1% diff
core/src/main/scala/kafka/tools/EndToEndLatency.scala changed 1.0% diff
core/src/main/scala/kafka/tools/GetOffsetShell.scala changed 2.8% diff
core/src/main/scala/kafka/tools/JmxTool.scala changed 0.4% diff
core/src/main/scala/kafka/tools/MirrorMaker.scala changed 4.2% diff
core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala changed 3.4% diff
core/src/main/scala/kafka/tools/StateChangeLogMerger.scala changed 0.5% diff
core/src/main/scala/kafka/utils/Throttler.scala changed 2.3% diff
core/src/test/scala/kafka/tools/LogCompactionTester.scala changed 2.4% diff
core/src/test/scala/other/kafka/ReplicationQuotasTestRig.scala changed 6.5% diff
core/src/test/scala/other/kafka/StressTestLog.scala changed 7.6% diff
core/src/test/scala/other/kafka/TestLinearWriteSpeed.scala changed 1.1% diff
core/src/test/scala/unit/kafka/admin/AclCommandTest.scala changed 45.9% diff
core/src/test/scala/unit/kafka/admin/ConfigCommandTest.scala changed 23.7% diff
core/src/test/scala/unit/kafka/admin/LeaderElectionCommandTest.scala added
core/src/test/scala/unit/kafka/admin/ReassignPartitionsCommandArgsTest.scala changed 0.7% diff
core/src/test/scala/unit/kafka/admin/ResetConsumerGroupOffsetTest.scala changed 29.1% diff
core/src/test/scala/unit/kafka/api/ApiUtilsTest.scala changed 3.3% diff
core/src/test/scala/unit/kafka/api/ApiVersionTest.scala changed 22.9% diff
core/src/test/scala/unit/kafka/cluster/PartitionTest.scala changed 71.2% diff
core/src/test/scala/unit/kafka/cluster/ReplicaTest.scala changed 24.5% diff
core/src/test/scala/unit/kafka/controller/ControllerChannelManagerTest.scala changed 26.1% diff
core/src/test/scala/unit/kafka/controller/ControllerContextTest.scala added
core/src/test/scala/unit/kafka/controller/ControllerEventManagerTest.scala changed 4.6% diff
core/src/test/scala/unit/kafka/controller/PartitionStateMachineTest.scala changed 23.4% diff
core/src/test/scala/unit/kafka/controller/ReplicaStateMachineTest.scala changed 3.3% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorTest.scala changed 22.7% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala changed 16.2% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataTest.scala changed 17.6% diff
core/src/test/scala/unit/kafka/coordinator/group/MemberMetadataTest.scala changed 7.6% diff
core/src/test/scala/unit/kafka/coordinator/transaction/ProducerIdManagerTest.scala changed 2.4% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionLogTest.scala changed 2.6% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionStateManagerTest.scala changed 7.9% diff
core/src/test/scala/unit/kafka/log/LogCleanerTest.scala changed 1.0% diff
core/src/test/scala/unit/kafka/log/LogConfigTest.scala changed 53.5% diff
core/src/test/scala/unit/kafka/log/LogManagerTest.scala changed 40.0% diff
core/src/test/scala/unit/kafka/log/LogSegmentTest.scala changed 10.1% diff
core/src/test/scala/unit/kafka/log/LogTest.scala changed 13.0% diff
core/src/test/scala/unit/kafka/log/LogValidatorTest.scala changed 32.2% diff
core/src/test/scala/unit/kafka/log/OffsetIndexTest.scala changed 4.9% diff
core/src/test/scala/unit/kafka/log/OffsetMapTest.scala changed 5.8% diff
core/src/test/scala/unit/kafka/log/ProducerStateManagerTest.scala changed 12.2% diff
core/src/test/scala/unit/kafka/log/TimeIndexTest.scala changed 4.6% diff
core/src/test/scala/unit/kafka/metrics/KafkaTimerTest.scala changed 4.3% diff
core/src/test/scala/unit/kafka/network/SocketServerTest.scala changed 14.4% diff
core/src/test/scala/unit/kafka/server/AbstractFetcherManagerTest.scala changed 33.8% diff
core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala changed 0.3% diff
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala changed 5.8% diff
core/src/test/scala/unit/kafka/server/DelayedOperationTest.scala changed 33.3% diff
core/src/test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala changed 12.7% diff
core/src/test/scala/unit/kafka/server/epoch/LeaderEpochFileCacheTest.scala changed 2.5% diff
core/src/test/scala/unit/kafka/server/epoch/OffsetsForLeaderEpochTest.scala changed 5.8% diff
core/src/test/scala/unit/kafka/server/HighwatermarkPersistenceTest.scala changed 27.3% diff
core/src/test/scala/unit/kafka/server/ISRExpirationTest.scala renamed 57.4% diff
core/src/test/scala/unit/kafka/server/IsrExpirationTest.scala
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala changed 28.2% diff
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala changed 4.3% diff
core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala changed 46.9% diff
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala changed 21.3% diff
core/src/test/scala/unit/kafka/server/ReplicaFetcherThreadTest.scala changed 20.2% diff
core/src/test/scala/unit/kafka/server/ReplicaManagerQuotasTest.scala changed 17.4% diff
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala changed 100.0% diff
core/src/test/scala/unit/kafka/server/ReplicationQuotaManagerTest.scala changed 10.6% diff
core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala changed 22.8% diff
core/src/test/scala/unit/kafka/server/ThrottledChannelExpirationTest.scala changed 2.4% diff
core/src/test/scala/unit/kafka/tools/ConsoleConsumerTest.scala changed 6.0% diff
core/src/test/scala/unit/kafka/tools/ConsoleProducerTest.scala changed 3.2% diff
core/src/test/scala/unit/kafka/tools/DumpLogSegmentsTest.scala changed 32.3% diff
core/src/test/scala/unit/kafka/tools/MirrorMakerTest.scala changed 6.6% diff
core/src/test/scala/unit/kafka/utils/CommandLineUtilsTest.scala changed 3.0% diff
core/src/test/scala/unit/kafka/utils/json/JsonValueTest.scala changed 0.5% diff
core/src/test/scala/unit/kafka/utils/JsonTest.scala changed 2.0% diff
core/src/test/scala/unit/kafka/utils/SchedulerTest.scala changed 36.0% diff
core/src/test/scala/unit/kafka/utils/ThrottlerTest.scala changed 1.8% diff
core/src/test/scala/unit/kafka/utils/timer/TimerTaskListTest.scala changed 0.9% diff
core/src/test/scala/unit/kafka/utils/timer/TimerTest.scala changed 0.8% diff
core/src/test/scala/unit/kafka/utils/TopicFilterTest.scala changed 1.6% diff
core/src/test/scala/unit/kafka/zk/ReassignPartitionsZNodeTest.scala changed 5.3% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/TopologyTest.scala changed 6.2% diff

Java Programs (938 of 2395):

NameStatusDeltaVisual Diff
clients/src/main/java/org/apache/kafka/clients/admin/Admin.java added
clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java changed 99.1% diff
clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java changed 5.7% diff
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigOp.java changed 2.7% diff
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsOptions.java changed 6.6% diff
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsResult.java changed 7.6% diff
clients/src/main/java/org/apache/kafka/clients/admin/AlterPartitionReassignmentsOptions.java added
clients/src/main/java/org/apache/kafka/clients/admin/AlterPartitionReassignmentsResult.java added
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsOptions.java changed 7.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsResult.java changed 4.6% diff
clients/src/main/java/org/apache/kafka/clients/admin/Config.java changed 3.2% diff
clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java changed 2.0% diff
clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java changed 7.5% diff
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsOptions.java changed 8.8% diff
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsResult.java changed 7.8% diff
clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenOptions.java changed 8.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenResult.java changed 4.6% diff
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsOptions.java changed 8.0% diff
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsResult.java changed 8.2% diff
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsOptions.java changed 6.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsResult.java changed 100.0% diff
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsOptions.java changed 9.3% diff
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsResult.java changed 3.4% diff
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsOptions.java added
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResult.java added
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsOptions.java changed 12.7% diff
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsResult.java changed 8.5% diff
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsOptions.java changed 12.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsResult.java changed 7.5% diff
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsOptions.java changed 8.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsResult.java changed 8.3% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsOptions.java changed 9.1% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsResult.java changed 4.7% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterOptions.java changed 6.3% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterResult.java changed 2.7% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsOptions.java changed 7.0% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsResult.java changed 2.6% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsOptions.java changed 11.1% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsResult.java changed 2.5% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeDelegationTokenOptions.java changed 9.8% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeDelegationTokenResult.java changed 4.5% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsOptions.java changed 11.7% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsResult.java changed 5.1% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsOptions.java changed 12.2% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsResult.java changed 2.6% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsOptions.java changed 7.3% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsResult.java changed 2.7% diff
clients/src/main/java/org/apache/kafka/clients/admin/ElectLeadersOptions.java added
clients/src/main/java/org/apache/kafka/clients/admin/ElectLeadersResult.java added
clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersOptions.java changed 22.6% diff
clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersResult.java changed 65.2% diff
clients/src/main/java/org/apache/kafka/clients/admin/ExpireDelegationTokenOptions.java changed 11.5% diff
clients/src/main/java/org/apache/kafka/clients/admin/ExpireDelegationTokenResult.java changed 5.0% diff
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java changed 33.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java changed 7.6% diff
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult.java changed 8.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsOptions.java changed 11.5% diff
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsResult.java changed 3.6% diff
clients/src/main/java/org/apache/kafka/clients/admin/ListPartitionReassignmentsOptions.java added
clients/src/main/java/org/apache/kafka/clients/admin/ListPartitionReassignmentsResult.java added
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsOptions.java changed 6.0% diff
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsResult.java changed 5.5% diff
clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java changed 38.4% diff
clients/src/main/java/org/apache/kafka/clients/admin/MemberToRemove.java added
clients/src/main/java/org/apache/kafka/clients/admin/NewPartitionReassignment.java added
clients/src/main/java/org/apache/kafka/clients/admin/NewPartitions.java changed 4.8% diff
clients/src/main/java/org/apache/kafka/clients/admin/NewTopic.java changed 25.4% diff
clients/src/main/java/org/apache/kafka/clients/admin/PartitionReassignment.java added
clients/src/main/java/org/apache/kafka/clients/admin/RecordsToDelete.java changed 7.6% diff
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupOptions.java added
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResult.java added
clients/src/main/java/org/apache/kafka/clients/admin/RenewDelegationTokenOptions.java changed 11.5% diff
clients/src/main/java/org/apache/kafka/clients/admin/RenewDelegationTokenResult.java changed 5.0% diff
clients/src/main/java/org/apache/kafka/clients/admin/TopicDescription.java changed 3.7% diff
clients/src/main/java/org/apache/kafka/clients/ApiVersion.java added
clients/src/main/java/org/apache/kafka/clients/ClientRequest.java changed 11.1% diff
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java changed 60.5% diff
clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java changed 5.2% diff
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java changed 11.1% diff
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerGroupMetadata.java added
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java added
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java changed 100.0% diff
clients/src/main/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignor.java added
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java changed 30.7% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor.java changed 50.7% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java added
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java changed 48.8% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java changed 2.7% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java changed 100.0% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java changed 11.7% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetcherMetricsRegistry.java changed 4.5% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Heartbeat.java changed 27.8% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/KafkaConsumerMetrics.java added
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignor.java changed 11.2% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignorAdapter.java added
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java changed 8.7% diff
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java changed 6.0% diff
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java changed 4.6% diff
clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java changed 48.2% diff
clients/src/main/java/org/apache/kafka/clients/consumer/RoundRobinAssignor.java changed 73.7% diff
clients/src/main/java/org/apache/kafka/clients/consumer/StickyAssignor.java changed 83.5% diff
clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java changed 5.2% diff
clients/src/main/java/org/apache/kafka/clients/GroupRebalanceConfig.java added
clients/src/main/java/org/apache/kafka/clients/Metadata.java changed 13.1% diff
clients/src/main/java/org/apache/kafka/clients/MetadataCache.java changed 6.6% diff
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java changed 2.7% diff
clients/src/main/java/org/apache/kafka/clients/NodeApiVersions.java changed 15.8% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/DefaultPartitioner.java changed 45.5% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java changed 6.3% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java changed 1.0% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/StickyPartitionCache.java added
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 2.7% diff
clients/src/main/java/org/apache/kafka/clients/producer/Partitioner.java changed 28.5% diff
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java changed 3.1% diff
clients/src/main/java/org/apache/kafka/clients/producer/RoundRobinPartitioner.java added
clients/src/main/java/org/apache/kafka/clients/producer/UniformStickyPartitioner.java added
clients/src/main/java/org/apache/kafka/common/Cluster.java changed 0.2% diff
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java changed 4.5% diff
clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java changed 4.8% diff
clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java changed 2.8% diff
clients/src/main/java/org/apache/kafka/common/config/internals/BrokerSecurityConfigs.java changed 3.1% diff
clients/src/main/java/org/apache/kafka/common/config/LogLevelConfig.java added
clients/src/main/java/org/apache/kafka/common/config/SecurityConfig.java added
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java changed 3.4% diff
clients/src/main/java/org/apache/kafka/common/ElectionType.java added
clients/src/main/java/org/apache/kafka/common/Endpoint.java added
clients/src/main/java/org/apache/kafka/common/errors/ElectionNotNeededException.java added
clients/src/main/java/org/apache/kafka/common/errors/EligibleLeadersNotAvailableException.java added
clients/src/main/java/org/apache/kafka/common/errors/GroupAuthorizationException.java changed 48.7% diff
clients/src/main/java/org/apache/kafka/common/errors/GroupMaxSizeReachedException.java changed 13.1% diff
clients/src/main/java/org/apache/kafka/common/errors/GroupSubscribedToTopicException.java added
clients/src/main/java/org/apache/kafka/common/errors/NoReassignmentInProgressException.java added
clients/src/main/java/org/apache/kafka/common/errors/TopicAuthorizationException.java changed 42.9% diff
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java changed 1.0% diff
clients/src/main/java/org/apache/kafka/common/internals/Topic.java changed 2.3% diff
clients/src/main/java/org/apache/kafka/common/MetricName.java changed 5.2% diff
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java changed 5.8% diff
clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java changed 0.02% diff
clients/src/main/java/org/apache/kafka/common/metrics/MeasurableStat.java changed 9.8% diff
clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java changed 2.1% diff
clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java changed 1.9% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/Count.java changed 37.8% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/CumulativeSum.java added
clients/src/main/java/org/apache/kafka/common/metrics/stats/Meter.java changed 27.3% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java changed 11.9% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/Sum.java changed 37.9% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/Total.java changed 42.8% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/WindowedCount.java added
clients/src/main/java/org/apache/kafka/common/metrics/stats/WindowedSum.java added
clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java changed 1.0% diff
clients/src/main/java/org/apache/kafka/common/network/NetworkSend.java changed 13.3% diff
clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java changed 7.2% 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 3.0% diff
clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java changed 0.3% diff
clients/src/main/java/org/apache/kafka/common/network/TransportLayer.java changed 2.7% diff
clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java changed 26.0% diff
clients/src/main/java/org/apache/kafka/common/protocol/ByteBufferAccessor.java changed 17.0% diff
clients/src/main/java/org/apache/kafka/common/protocol/CommonFields.java changed 5.5% diff
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java changed 5.2% diff
clients/src/main/java/org/apache/kafka/common/protocol/Message.java changed 24.0% diff
clients/src/main/java/org/apache/kafka/common/protocol/MessageUtil.java changed 28.1% diff
clients/src/main/java/org/apache/kafka/common/protocol/ObjectSerializationCache.java added
clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java changed 20.1% diff
clients/src/main/java/org/apache/kafka/common/protocol/Readable.java changed 38.6% diff
clients/src/main/java/org/apache/kafka/common/protocol/types/ArrayOf.java changed 3.2% diff
clients/src/main/java/org/apache/kafka/common/protocol/types/CompactArrayOf.java added
clients/src/main/java/org/apache/kafka/common/protocol/types/Field.java changed 37.9% diff
clients/src/main/java/org/apache/kafka/common/protocol/types/RawTaggedField.java added
clients/src/main/java/org/apache/kafka/common/protocol/types/RawTaggedFieldWriter.java added
clients/src/main/java/org/apache/kafka/common/protocol/types/Schema.java changed 2.8% diff
clients/src/main/java/org/apache/kafka/common/protocol/types/Struct.java changed 5.7% diff
clients/src/main/java/org/apache/kafka/common/protocol/types/TaggedFields.java added
clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java changed 47.9% diff
clients/src/main/java/org/apache/kafka/common/protocol/Writable.java changed 56.6% diff
clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java changed 2.7% diff
clients/src/main/java/org/apache/kafka/common/record/AbstractRecordBatch.java changed 0.2% diff
clients/src/main/java/org/apache/kafka/common/record/AbstractRecords.java changed 3.4% diff
clients/src/main/java/org/apache/kafka/common/record/ControlRecordType.java changed 1.4% diff
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java changed 43.2% diff
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java changed 15.0% diff
clients/src/main/java/org/apache/kafka/common/record/EndTransactionMarker.java changed 1.1% diff
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java changed 0.4% diff
clients/src/main/java/org/apache/kafka/common/record/InvalidRecordException.java moved 14.5% diff
clients/src/main/java/org/apache/kafka/common/InvalidRecordException.java
clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockInputStream.java changed 19.3% diff
clients/src/main/java/org/apache/kafka/common/record/LazyDownConversionRecords.java changed 3.2% diff
clients/src/main/java/org/apache/kafka/common/record/LegacyRecord.java changed 1.2% diff
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java changed 3.6% diff
clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java changed 0.6% diff
clients/src/main/java/org/apache/kafka/common/record/MutableRecordBatch.java changed 24.0% diff
clients/src/main/java/org/apache/kafka/common/record/PartialDefaultRecord.java added
clients/src/main/java/org/apache/kafka/common/replica/ClientMetadata.java added
clients/src/main/java/org/apache/kafka/common/replica/PartitionView.java added
clients/src/main/java/org/apache/kafka/common/replica/RackAwareReplicaSelector.java added
clients/src/main/java/org/apache/kafka/common/replica/ReplicaSelector.java added
clients/src/main/java/org/apache/kafka/common/replica/ReplicaView.java added
clients/src/main/java/org/apache/kafka/common/requests/AbstractControlRequest.java changed 48.2% diff
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java changed 6.2% diff
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequestResponse.java changed 37.4% diff
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java changed 26.6% diff
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponse.java changed 0.8% diff
clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsResponse.java added
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java changed 0.8% diff
clients/src/main/java/org/apache/kafka/common/requests/ApiError.java changed 2.4% diff
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsRequest.java changed 58.9% diff
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java changed 82.2% diff
clients/src/main/java/org/apache/kafka/common/requests/BasePartitionState.java removed
clients/src/main/java/org/apache/kafka/common/requests/ControlledShutdownRequest.java changed 20.3% diff
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenRequest.java changed 67.0% diff
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java changed 81.7% diff
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsRequest.java changed 26.0% diff
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsRequest.java changed 59.4% diff
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsResponse.java changed 71.8% diff
clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsRequest.java changed 35.2% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java changed 0.5% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenRequest.java changed 68.9% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenResponse.java changed 78.1% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java changed 1.5% diff
clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersResponse.java added
clients/src/main/java/org/apache/kafka/common/requests/ElectPreferredLeadersRequest.java renamed 74.1% diff
clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersRequest.java
clients/src/main/java/org/apache/kafka/common/requests/ElectPreferredLeadersResponse.java removed
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenRequest.java changed 58.3% diff
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenResponse.java changed 63.4% diff
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java changed 0.3% diff
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java changed 0.9% diff
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java changed 20.5% diff
clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsRequest.java changed 4.9% diff
clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsResponse.java changed 15.2% diff
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java changed 84.7% diff
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrResponse.java changed 66.5% diff
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupRequest.java changed 78.0% diff
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupResponse.java changed 100.0% diff
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsRequest.java changed 50.9% diff
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java changed 75.5% diff
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java changed 0.4% diff
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java changed 0.8% diff
clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsResponse.java added
clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java changed 14.8% diff
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java changed 17.8% diff
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java changed 32.3% diff
clients/src/main/java/org/apache/kafka/common/requests/OffsetDeleteRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/OffsetDeleteResponse.java added
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java changed 69.4% diff
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java changed 61.6% diff
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java changed 2.4% diff
clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java changed 48.1% diff
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenRequest.java changed 60.1% diff
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenResponse.java changed 63.4% diff
clients/src/main/java/org/apache/kafka/common/requests/RequestContext.java changed 27.1% diff
clients/src/main/java/org/apache/kafka/common/requests/RequestHeader.java changed 72.2% diff
clients/src/main/java/org/apache/kafka/common/requests/RequestUtils.java changed 5.9% diff
clients/src/main/java/org/apache/kafka/common/requests/ResponseHeader.java changed 54.2% diff
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaRequest.java changed 65.7% diff
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaResponse.java changed 65.7% diff
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitRequest.java changed 77.6% diff
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java changed 77.5% diff
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataRequest.java changed 89.1% diff
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataResponse.java changed 54.4% diff
clients/src/main/java/org/apache/kafka/common/security/auth/SecurityProviderCreator.java added
clients/src/main/java/org/apache/kafka/common/security/authenticator/LoginManager.java changed 1.1% diff
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java changed 2.9% diff
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java changed 2.4% diff
clients/src/main/java/org/apache/kafka/common/security/JaasUtils.java changed 67.6% diff
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosRule.java changed 5.5% diff
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosShortNamer.java changed 6.3% diff
clients/src/main/java/org/apache/kafka/common/security/ssl/SslEngineBuilder.java changed 2.5% diff
clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java changed 7.4% diff
clients/src/main/java/org/apache/kafka/common/security/ssl/SslPrincipalMapper.java changed 20.5% diff
clients/src/main/java/org/apache/kafka/common/TopicPartitionReplica.java changed 3.8% diff
clients/src/main/java/org/apache/kafka/common/utils/Bytes.java changed 16.2% diff
clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java changed 28.4% diff
clients/src/main/java/org/apache/kafka/common/utils/CloseableIterator.java changed 39.8% diff
clients/src/main/java/org/apache/kafka/common/utils/FlattenedIterator.java added
clients/src/main/java/org/apache/kafka/common/utils/MappedIterator.java added
clients/src/main/java/org/apache/kafka/common/utils/PrimitiveRef.java added
clients/src/main/java/org/apache/kafka/common/utils/SecurityUtils.java changed 100.0% diff
clients/src/main/java/org/apache/kafka/common/utils/SystemTime.java changed 9.0% diff
clients/src/main/java/org/apache/kafka/common/utils/Utils.java changed 1.9% diff
clients/src/main/java/org/apache/kafka/server/authorizer/AclCreateResult.java added
clients/src/main/java/org/apache/kafka/server/authorizer/AclDeleteResult.java added
clients/src/main/java/org/apache/kafka/server/authorizer/Action.java added
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizableRequestContext.java added
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizationResult.java added
clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java added
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizerServerInfo.java added
clients/src/test/java/org/apache/kafka/clients/admin/AdminClientUnitTestEnv.java changed 3.4% diff
clients/src/test/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResultTest.java added
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java changed 76.4% diff
clients/src/test/java/org/apache/kafka/clients/admin/MemberDescriptionTest.java added
clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java changed 17.8% diff
clients/src/test/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupOptionsTest.java added
clients/src/test/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResultTest.java added
clients/src/test/java/org/apache/kafka/clients/ApiVersionsTest.java changed 14.4% diff
clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java changed 4.1% diff
clients/src/test/java/org/apache/kafka/clients/CommonClientConfigsTest.java changed 1.9% diff
clients/src/test/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignorTest.java added
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java changed 37.0% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignorTest.jav
a
added
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java added
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java changed 38.6% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocolTest.java changed 97.7% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java changed 5.1% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatTest.java changed 21.4% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/MockPartitionAssignor.java changed 18.8% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/PartitionAssignorAdapterTest.java added
clients/src/test/java/org/apache/kafka/clients/consumer/internals/SubscriptionStateTest.java changed 5.4% diff
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java changed 21.6% diff
clients/src/test/java/org/apache/kafka/clients/consumer/MockConsumerTest.java changed 8.1% diff
clients/src/test/java/org/apache/kafka/clients/consumer/RangeAssignorTest.java changed 100.0% diff
clients/src/test/java/org/apache/kafka/clients/consumer/RoundRobinAssignorTest.java changed 100.0% diff
clients/src/test/java/org/apache/kafka/clients/consumer/StickyAssignorTest.java changed 82.9% diff
clients/src/test/java/org/apache/kafka/clients/MetadataTest.java changed 38.1% diff
clients/src/test/java/org/apache/kafka/clients/MockClient.java changed 0.6% diff
clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java changed 36.5% diff
clients/src/test/java/org/apache/kafka/clients/NodeApiVersionsTest.java changed 29.8% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/DefaultPartitionerTest.java changed 72.0% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java changed 15.6% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java changed 8.7% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/StickyPartitionCacheTest.java added
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java changed 5.4% diff
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java changed 0.5% diff
clients/src/test/java/org/apache/kafka/clients/producer/RoundRobinPartitionerTest.java added
clients/src/test/java/org/apache/kafka/clients/producer/UniformStickyPartitionerTest.java added
clients/src/test/java/org/apache/kafka/common/config/ConfigDefTest.java changed 1.6% diff
clients/src/test/java/org/apache/kafka/common/message/ApiMessageTypeTest.java changed 40.4% diff
clients/src/test/java/org/apache/kafka/common/message/MessageTest.java changed 100.0% diff
clients/src/test/java/org/apache/kafka/common/message/SimpleExampleMessageTest.java added
clients/src/test/java/org/apache/kafka/common/metrics/JmxReporterTest.java changed 11.4% diff
clients/src/test/java/org/apache/kafka/common/metrics/KafkaMbeanTest.java changed 3.8% diff
clients/src/test/java/org/apache/kafka/common/metrics/MetricsTest.java changed 8.0% diff
clients/src/test/java/org/apache/kafka/common/metrics/SensorTest.java changed 14.2% diff
clients/src/test/java/org/apache/kafka/common/metrics/stats/FrequenciesTest.java changed 2.5% diff
clients/src/test/java/org/apache/kafka/common/metrics/stats/MeterTest.java changed 2.1% diff
clients/src/test/java/org/apache/kafka/common/network/SslSelectorTest.java changed 2.3% diff
clients/src/test/java/org/apache/kafka/common/protocol/MessageTestUtil.java added
clients/src/test/java/org/apache/kafka/common/protocol/MessageUtilTest.java changed 32.1% diff
clients/src/test/java/org/apache/kafka/common/protocol/types/ProtocolSerializationTest.java changed 39.5% diff
clients/src/test/java/org/apache/kafka/common/protocol/types/RawTaggedFieldWriterTest.java added
clients/src/test/java/org/apache/kafka/common/record/AbstractLegacyRecordBatchTest.java changed 0.5% diff
clients/src/test/java/org/apache/kafka/common/record/ByteBufferLogInputStreamTest.java changed 4.6% diff
clients/src/test/java/org/apache/kafka/common/record/DefaultRecordBatchTest.java changed 8.6% diff
clients/src/test/java/org/apache/kafka/common/record/DefaultRecordTest.java changed 95.0% diff
clients/src/test/java/org/apache/kafka/common/record/EndTransactionMarkerTest.java changed 2.0% diff
clients/src/test/java/org/apache/kafka/common/record/LegacyRecordTest.java changed 2.2% diff
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsTest.java changed 4.4% diff
clients/src/test/java/org/apache/kafka/common/record/SimpleLegacyRecordTest.java changed 5.9% diff
clients/src/test/java/org/apache/kafka/common/record/SimpleMemoryRecordsTest.java removed
clients/src/test/java/org/apache/kafka/common/replica/ReplicaSelectorTest.java added
clients/src/test/java/org/apache/kafka/common/requests/ApiVersionsResponseTest.java changed 36.3% diff
clients/src/test/java/org/apache/kafka/common/requests/ControlRequestTest.java renamed 77.3% diff
clients/src/test/java/org/apache/kafka/common/requests/ControlledShutdownRequestTest.java
clients/src/test/java/org/apache/kafka/common/requests/DeleteGroupsResponseTest.java added
clients/src/test/java/org/apache/kafka/common/requests/LeaderAndIsrRequestTest.java added
clients/src/test/java/org/apache/kafka/common/requests/LeaderAndIsrResponseTest.java changed 74.1% diff
clients/src/test/java/org/apache/kafka/common/requests/LeaveGroupRequestTest.java changed 100.0% diff
clients/src/test/java/org/apache/kafka/common/requests/LeaveGroupResponseTest.java changed 100.0% diff
clients/src/test/java/org/apache/kafka/common/requests/OffsetCommitRequestTest.java changed 100.0% diff
clients/src/test/java/org/apache/kafka/common/requests/OffsetCommitResponseTest.java added
clients/src/test/java/org/apache/kafka/common/requests/OffsetFetchRequestTest.java added
clients/src/test/java/org/apache/kafka/common/requests/OffsetFetchResponseTest.java added
clients/src/test/java/org/apache/kafka/common/requests/ProduceRequestTest.java changed 0.5% diff
clients/src/test/java/org/apache/kafka/common/requests/RequestContextTest.java changed 20.8% diff
clients/src/test/java/org/apache/kafka/common/requests/RequestHeaderTest.java changed 18.4% diff
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java changed 35.0% diff
clients/src/test/java/org/apache/kafka/common/requests/StopReplicaRequestTest.java added
clients/src/test/java/org/apache/kafka/common/requests/StopReplicaResponseTest.java changed 50.5% diff
clients/src/test/java/org/apache/kafka/common/requests/TxnOffsetCommitRequestTest.java added
clients/src/test/java/org/apache/kafka/common/requests/TxnOffsetCommitResponseTest.java added
clients/src/test/java/org/apache/kafka/common/requests/UpdateMetadataRequestTest.java added
clients/src/test/java/org/apache/kafka/common/security/auth/DefaultKafkaPrincipalBuilderTest.java changed 1.0% diff
clients/src/test/java/org/apache/kafka/common/security/authenticator/ClientAuthenticationFailureTes
t.java
changed 1.7% diff
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java changed 5.6% diff
clients/src/test/java/org/apache/kafka/common/security/kerberos/KerberosNameTest.java changed 30.2% diff
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestPlainSaslServerProvider.java added
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestPlainSaslServerProviderCreator.
java
added
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestProviderCreator.java added
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestScramSaslServerProvider.java added
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestScramSaslServerProviderCreator.
java
added
clients/src/test/java/org/apache/kafka/common/security/ssl/SslFactoryTest.java changed 10.5% diff
clients/src/test/java/org/apache/kafka/common/security/ssl/SslPrincipalMapperTest.java changed 70.5% diff
clients/src/test/java/org/apache/kafka/common/utils/BytesTest.java added
clients/src/test/java/org/apache/kafka/common/utils/ByteUtilsTest.java changed 17.7% diff
clients/src/test/java/org/apache/kafka/common/utils/FlattenedIteratorTest.java added
clients/src/test/java/org/apache/kafka/common/utils/MappedIteratorTest.java added
clients/src/test/java/org/apache/kafka/common/utils/SecurityUtilsTest.java changed 100.0% diff
clients/src/test/java/org/apache/kafka/common/utils/UtilsTest.java changed 3.5% diff
clients/src/test/java/org/apache/kafka/test/MetricsBench.java changed 6.3% diff
clients/src/test/java/org/apache/kafka/test/MockSelector.java changed 4.7% diff
clients/src/test/java/org/apache/kafka/test/TestUtils.java changed 24.9% diff
clients/src/test/java/org/apache/kafka/test/ValuelessCallable.java added
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java changed 48.0% diff
connect/api/src/main/java/org/apache/kafka/connect/storage/Converter.java changed 78.4% diff
connect/json/src/main/java/org/apache/kafka/connect/json/DecimalFormat.java added
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java changed 17.2% diff
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverterConfig.java changed 50.4% diff
connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java changed 27.9% diff
connect/json/src/test/java/org/apache/kafka/connect/json/JsonConverterConfigTest.java added
connect/json/src/test/java/org/apache/kafka/connect/json/JsonConverterTest.java changed 5.8% diff
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/Checkpoint.java added
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/DefaultReplicationPolicy.java added
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/Heartbeat.java added
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClient.java added
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClientConfig.java added
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/RemoteClusterUtils.java added
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/ReplicationPolicy.java added
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/SourceAndTarget.java added
connect/mirror-client/src/test/java/org/apache/kafka/connect/mirror/MirrorClientTest.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/ConfigPropertyFilter.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultConfigPropertyFilter.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultGroupFilter.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultTopicFilter.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/GroupFilter.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatConnector.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatTask.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMetrics.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceTask.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorTaskConfig.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorUtils.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSync.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/Scheduler.java added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/TopicFilter.java added
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/CheckpointTest.java added
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/HeartbeatTest.java added
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorCheckpointTaskTest.java added
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorConfigTest.java added
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java added
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorMakerConfigTest.java added
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceConnectorTest.java added
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceTaskTest.java added
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/OffsetSyncStoreTest.java added
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/OffsetSyncTest.java added
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java changed 2.1% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java changed 9.9% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ClusterConfigState.java changed 6.2% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocolCompatibi
lity.java
changed 66.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java changed 95.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java changed 16.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAs
signor.java
changed 6.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeCo
nnectProtocol.java
changed 20.1% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java changed 21.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java changed 4.7% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/DeadLetterQueueReporter.java changed 1.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ErrorHandlingMetrics.java changed 14.7% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Herder.java changed 4.1% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java changed 0.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java added
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.ja
va
changed 3.2% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/LoggingResource.java added
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java changed 29.8% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java changed 39.7% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/util/SSLUtils.java changed 18.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java added
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java changed 0.8% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java changed 3.7% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java changed 2.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java changed 13.2% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java changed 7.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java changed 3.2% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java changed 2.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java changed 4.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/CloseableOffsetStorageReader.java added
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConfigBackingStore.java changed 7.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java changed 9.8% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java changed 3.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryConfigBackingStore.java changed 2.6% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryOffsetBackingStore.java changed 6.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetBackingStore.java changed 11.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReaderImpl.java changed 40.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/tools/TransformationDoc.java changed 1.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectUtils.java changed 8.8% diff
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConvertingFutureCallback.java changed 55.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java changed 3.2% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectWorkerIntegrationTest.jav
a
changed 91.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ExampleConnectIntegrationTest.ja
va
changed 2.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSourceConnector.java changed 2.1% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/SessionedProtocolIntegrationTest
.java
added
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractHerderTest.java changed 0.9% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocolCompatibi
lityTest.java
changed 11.5% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedConfigTest.ja
va
added
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.ja
va
changed 7.4% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAs
signorTest.java
changed 7.6% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorIncreme
ntalTest.java
changed 7.8% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorTest.ja
va
changed 4.9% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java changed 0.5% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginUtilsTest.java changed 1.7% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignatureTest.ja
va
added
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResourceTes
t.java
changed 7.2% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/LoggingResourceTest.j
ava
added
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/RestServerTest.java changed 53.2% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/util/SSLUtilsTest.java changed 65.4% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java changed 0.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/TestConverterWithHeaders.java added
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConfigTest.java added
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskTest.java changed 8.7% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskThreadedTest.java changed 3.4% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java changed 16.6% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTest.java changed 14.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTestUtils.java changed 0.2% diff
connect/runtime/src/test/java/org/apache/kafka/connect/storage/FileOffsetBackingStoreTest.java changed 16.8% diff
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaConfigBackingStoreTest.java changed 0.1% diff
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java changed 11.6% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java changed 7.5% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java changed 13.1% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/WorkerHandle.java changed 7.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/ConvertingFutureCallbackTest.java added
core/src/main/scala/kafka/tools/StreamsResetter.java changed 8.4% diff
generator/src/main/java/org/apache/kafka/message/ApiMessageTypeGenerator.java changed 36.2% diff
generator/src/main/java/org/apache/kafka/message/ClauseGenerator.java added
generator/src/main/java/org/apache/kafka/message/FieldSpec.java changed 87.0% diff
generator/src/main/java/org/apache/kafka/message/FieldType.java changed 17.8% diff
generator/src/main/java/org/apache/kafka/message/HeaderGenerator.java changed 23.5% diff
generator/src/main/java/org/apache/kafka/message/IsNullConditional.java added
generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java changed 100.0% diff
generator/src/main/java/org/apache/kafka/message/MessageGenerator.java changed 29.1% diff
generator/src/main/java/org/apache/kafka/message/MessageSpec.java changed 60.7% diff
generator/src/main/java/org/apache/kafka/message/SchemaGenerator.java changed 57.4% diff
generator/src/main/java/org/apache/kafka/message/StructRegistry.java added
generator/src/main/java/org/apache/kafka/message/StructSpec.java changed 58.6% diff
generator/src/main/java/org/apache/kafka/message/VersionConditional.java added
generator/src/main/java/org/apache/kafka/message/Versions.java changed 46.6% diff
generator/src/test/java/org/apache/kafka/message/CodeBufferTest.java added
generator/src/test/java/org/apache/kafka/message/IsNullConditionalTest.java added
generator/src/test/java/org/apache/kafka/message/MessageDataGeneratorTest.java added
generator/src/test/java/org/apache/kafka/message/StructRegistryTest.java added
generator/src/test/java/org/apache/kafka/message/VersionConditionalTest.java added
generator/src/test/java/org/apache/kafka/message/VersionsTest.java changed 30.5% diff
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/cache/LRUCacheBenchmark.java changed 3.0% diff
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchIterationBenchmark.java changed 17.4% diff
streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java changed 3.6% diff
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java changed 16.0% diff
streams/examples/src/test/java/org/apache/kafka/streams/examples/docs/DeveloperGuideTesting.java added
streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountDemoTest.java added
streams/src/main/java/org/apache/kafka/streams/internals/metrics/ClientMetrics.java added
streams/src/main/java/org/apache/kafka/streams/KafkaClientSupplier.java changed 25.5% diff
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java changed 9.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java changed 2.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKey.java added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKeySchema.j
ava
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscrip
tionProcessorSupplier.java
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscrip
tionSendProcessorSupplier.java
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionJoinFor
eignProcessorSupplier.java
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResolve
rJoinProcessorSupplier.java
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionRespons
eWrapper.java
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionRespons
eWrapperSerde.java
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionStoreRe
ceiveProcessorSupplier.java
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper
.java
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper
Serde.java
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/FullChangeSerde.java changed 70.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseRepartitionNode.java changed 15.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GroupedTableOperationReparti
tionNode.java
changed 0.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableForeignKeyJoinRe
solutionNode.java
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.j
ava
changed 10.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorGraphNode.java changed 10.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java changed 34.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSinkNode.java changed 11.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java changed 2.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java changed 3.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java changed 25.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java changed 31.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java changed 6.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java changed 36.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java changed 6.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java changed 8.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java changed 6.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java changed 3.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java changed 4.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java changed 83.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java changed 5.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java changed 4.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoin.java changed 4.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java changed 5.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java changed 6.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSourceValueGetterSupplier.ja
va
changed 5.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/metrics/Sensors.java changed 21.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/NamedInternal.java changed 16.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java changed 26.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/StreamJoinedInternal.java added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/TimeDefinitions.java changed 1.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindow.java changed 3.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java changed 24.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/UnlimitedWindow.java changed 3.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java changed 1.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java changed 62.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java changed 81.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java changed 63.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedDeserializer.java changed 4.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedKStream.java changed 91.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedSerializer.java changed 6.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java changed 3.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java added
streams/src/main/java/org/apache/kafka/streams/kstream/Suppressed.java changed 1.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java changed 4.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java changed 90.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedSerializer.java changed 6.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java changed 1.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/WindowedSerdes.java changed 28.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java changed 9.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/DefaultPartitionGrouper.java changed 2.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java changed 2.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java changed 2.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java changed 18.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStandbyTasks.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasks.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java changed 52.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java changed 31.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration
.java
added
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorError.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java changed 21.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/CopartitionedTopicsEn
forcer.java
added
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignor.ja
va
changed 3.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StreamsAssignmentProt
ocolVersions.java
added
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java changed 8.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogReader.java changed 25.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultKafkaClientSupplier.java changed 9.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java changed 6.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java changed 9.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java changed 2.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java changed 19.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicConfig.java changed 12.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java changed 8.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java changed 3.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/CumulativeCount.java moved 36.3% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/CumulativeCount.java
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java changed 10.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java changed 0.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java changed 34.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java changed 0.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java changed 1.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java changed 11.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java changed 10.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecoverableClientException.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java changed 8.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java changed 62.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java changed 23.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java changed 70.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListener.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java changed 28.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java changed 22.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java changed 11.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java changed 61.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java changed 2.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/PartitionGrouper.java changed 3.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/Processor.java changed 3.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java changed 0.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreCallback.java changed 8.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/TimestampExtractor.java changed 3.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/TopicNameExtractor.java changed 5.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java changed 8.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java changed 4.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractMergedSortedCacheStoreIterat
or.java
changed 2.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.j
ava
changed 2.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/BufferValue.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java changed 0.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java changed 0.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeKeyValueIterator.java changed 5.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ContextualRecord.java changed 4.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/DelegatingPeekingKeyValueIterator.ja
va
changed 5.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/FilteredCacheIterator.java changed 6.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java changed 1.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionBytesStoreSupplier.ja
va
changed 2.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java changed 2.9% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.ja
va
changed 10.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowBytesStoreSupplier.jav
a
changed 12.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java changed 1.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueIterators.java changed 2.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegment.java changed 11.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegments.java changed 22.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/LRUCacheEntry.java changed 1.9% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/Maybe.java changed 2.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java changed 2.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java changed 26.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java changed 20.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowedKeyValueIterator.java changed 2.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java changed 22.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreIterator.java changed 3.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/NamedCacheMetrics.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecordingTrigg
er.java
added
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/Sensors.java changed 26.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/Murmur3.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java changed 24.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColu
mnFamilyOptionsAdapter.java
changed 1.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbIterator.java changed 5.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbKeyValueBytesStoreSupplier.ja
va
changed 10.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBPrefixIterator.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java changed 13.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbSessionBytesStoreSupplier.jav
a
changed 1.9% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java changed 7.9% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedSegmentedBytesStor
e.java
changed 13.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java changed 2.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbWindowBytesStoreSupplier.java changed 1.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java changed 1.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java changed 4.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java changed 1.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegment.java changed 11.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegments.java changed 22.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java changed 0.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreIteratorWrapper.java changed 8.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowToTimestampedWindowByteStoreAd
apter.java
changed 0.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedSessionStoreIterator.java changed 7.9% diff
streams/src/main/java/org/apache/kafka/streams/state/KeyValueIterator.java changed 3.7% diff
streams/src/main/java/org/apache/kafka/streams/state/RocksDBConfigSetter.java changed 12.4% diff
streams/src/main/java/org/apache/kafka/streams/state/Stores.java changed 0.6% diff
streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java changed 2.4% diff
streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java changed 3.5% diff
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java changed 5.5% diff
streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java changed 1.4% diff
streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java changed 54.3% diff
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java changed 0.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java changed 2.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/ForeignKeyJoinSuite.java added
streams/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java changed 10.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java changed 2.2% diff
streams/src/test/java/org/apache/kafka/streams/integration/KStreamTransformIntegrationTest.java changed 3.0% diff
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiInte
grationTest.java
added
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTes
t.java
added
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinMaterializatio
nIntegrationTest.java
added
streams/src/test/java/org/apache/kafka/streams/integration/MetricsIntegrationTest.java changed 95.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/OptimizedKTableIntegrationTest.java added
streams/src/test/java/org/apache/kafka/streams/integration/PurgeRepartitionTopicIntegrationTest.jav
a
changed 1.7% diff
streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java changed 2.8% diff
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java changed 8.5% diff
streams/src/test/java/org/apache/kafka/streams/integration/RepartitionOptimizingIntegrationTest.jav
a
removed
streams/src/test/java/org/apache/kafka/streams/integration/RepartitionWithMergeOptimizingIntegratio
nTest.java
removed
streams/src/test/java/org/apache/kafka/streams/integration/ResetPartitionTimeIntegrationTest.java added
streams/src/test/java/org/apache/kafka/streams/integration/StreamStreamJoinIntegrationTest.java changed 76.4% diff
streams/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinIntegrationTest.java changed 26.8% diff
streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java changed 71.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/utils/CompositeStateListener.java added
streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java changed 3.9% diff
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java changed 13.8% diff
streams/src/test/java/org/apache/kafka/streams/integration/utils/KafkaEmbedded.java changed 3.1% diff
streams/src/test/java/org/apache/kafka/streams/internals/metrics/ClientMetricsTest.java added
streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java changed 74.6% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/AbstractStreamTest.java changed 4.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKeySchemaTe
st.java
added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResolve
rJoinProcessorSupplierTest.java
added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionRespons
eWrapperSerdeTest.java
added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper
SerdeTest.java
added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/FullChangeSerdeTest.java changed 75.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/GlobalKTableJoinsTest.java changed 13.7% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImplTest.java changed 10.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImplTest.java changed 7.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamBranchTest.java changed 8.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFilterTest.java changed 12.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapTest.java changed 22.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapValuesTest.java changed 36.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamForeachTest.java changed 7.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableJoinTest.java changed 22.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableLeftJoinTest.ja
va
changed 33.5% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java changed 24.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java changed 33.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamLeftJoinTest.java changed 27.2% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinTest.java changed 22.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKTableLeftJoinTest.java changed 33.7% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamMapTest.java changed 24.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamMapValuesTest.java changed 28.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamPeekTest.java changed 8.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSelectKeyTest.java changed 19.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregateProce
ssorTest.java
changed 2.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamTransformTest.java changed 25.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValuesTest.java changed 21.2% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregateTest.java changed 56.2% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableAggregateTest.java changed 35.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableFilterTest.java changed 33.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableImplTest.java changed 9.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoinTest.java changed 42.2% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoinTest.java changed 44.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoinTest.java changed 53.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableMapKeysTest.java changed 21.6% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableMapValuesTest.java changed 29.2% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableSourceTest.java changed 42.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableTransformValuesTest.java changed 11.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImplTest.jav
a
changed 7.2% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorMe
tricsTest.java
changed 29.6% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorTe
st.java
changed 1.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/SuppressSuite.java changed 14.5% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SuppressScenarioTest.java changed 20.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImplTest.java changed 6.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/RepartitionTopicNamingTest.java changed 7.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/WindowedSerdesTest.java changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java changed 0.2% diff
streams/src/test/java/org/apache/kafka/streams/processor/DefaultPartitionGrouperTest.java changed 0.7% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/AbstractTaskTest.java changed 17.4% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java changed 48.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfoTest.ja
va
changed 35.9% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ClientStateTest.java changed 4.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignorTes
t.java
changed 4.9% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfoTest.
java
changed 33.7% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/CopartitionedTopicsValidatorTest
.java
renamed 45.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/CopartitionedTopicsEnforcerTest.java
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java changed 3.9% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStreamThreadTest.java changed 11.7% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java changed 1.9% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImplTest.j
ava
changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetricsTest.java added
streams/src/test/java/org/apache/kafka/streams/processor/internals/MockChangelogReader.java changed 19.9% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/MockStreamsMetrics.java changed 6.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/PartitionGroupTest.java changed 23.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java changed 1.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorNodeTest.java changed 47.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContextTest.java changed 12.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java changed 37.7% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java changed 5.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordQueueTest.java changed 7.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionOptimizingTest.java added
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionWithMergeOptimizingTe
st.java
added
streams/src/test/java/org/apache/kafka/streams/processor/internals/SingleGroupPartitionGrouperStub.
java
changed 21.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java changed 11.9% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java changed 6.4% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.jav
a
changed 54.4% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java changed 30.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java changed 20.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java changed 18.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskSuite.java added
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStoreTe
st.java
changed 0.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/BufferValueTest.java added
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingWindowStoreTest.java changed 5.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedWindowBytesS
toreTest.java
changed 1.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStoreTest.ja
va
changed 1.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/GlobalStateStoreProviderTest.java changed 2.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryWindowStoreTest.java changed 0.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueSegmentsTest.java changed 4.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueSegmentTest.java changed 37.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStoreTest.java changed 8.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredSessionStoreTest.java changed 6.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStoreTest.
java
changed 7.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStoreTest.ja
va
changed 3.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreTest.java changed 25.1% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/NamedCacheMetricsTest.java added
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderTest.j
ava
added
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecordingTrigg
erTest.java
added
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsTest.java added
streams/src/test/java/org/apache/kafka/streams/state/internals/Murmur3Test.java added
streams/src/test/java/org/apache/kafka/streams/state/internals/NamedCacheTest.java changed 14.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ReadOnlyWindowStoreStub.java changed 6.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColu
mnFamilyOptionsAdapterTest.java
changed 17.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBKeyValueStoreTest.java changed 2.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStoreTest.java changed 12.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java changed 30.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedSegmentedBytesStor
eTest.java
changed 12.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStoreTest.java changed 0.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreTest.java changed 1.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/SegmentIteratorTest.java changed 7.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionBytesStoreTest.java changed 0.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProviderTest.j
ava
changed 1.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferTest.java changed 8.1% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilderTest.
java
changed 2.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedSegmentsTest.java changed 4.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedSegmentTest.java changed 38.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowBytesStoreTest.java changed 1.0% diff
streams/src/test/java/org/apache/kafka/streams/state/KeyValueStoreTestDriver.java changed 0.4% diff
streams/src/test/java/org/apache/kafka/streams/state/NoOpWindowStore.java changed 1.8% diff
streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java changed 99.2% diff
streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java changed 5.5% diff
streams/src/test/java/org/apache/kafka/streams/tests/BrokerCompatibilityTest.java changed 1.4% diff
streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java changed 1.4% diff
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java changed 0.5% diff
streams/src/test/java/org/apache/kafka/streams/tests/StaticMemberTestClient.java added
streams/src/test/java/org/apache/kafka/streams/tests/StreamsBrokerDownResilienceTest.java changed 7.8% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsNamedRepartitionTest.java changed 0.1% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java changed 1.9% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java changed 25.1% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java added
streams/src/test/java/org/apache/kafka/test/GenericInMemoryKeyValueStore.java changed 1.6% diff
streams/src/test/java/org/apache/kafka/test/GenericInMemoryTimestampedKeyValueStore.java changed 1.5% diff
streams/src/test/java/org/apache/kafka/test/InternalMockProcessorContext.java changed 7.7% diff
streams/src/test/java/org/apache/kafka/test/KeyValueIteratorStub.java changed 3.4% diff
streams/src/test/java/org/apache/kafka/test/MockClientSupplier.java changed 5.7% diff
streams/src/test/java/org/apache/kafka/test/MockInternalTopicManager.java changed 7.5% diff
streams/src/test/java/org/apache/kafka/test/MockKeyValueStore.java changed 21.1% diff
streams/src/test/java/org/apache/kafka/test/MockProcessor.java changed 22.0% diff
streams/src/test/java/org/apache/kafka/test/ReadOnlySessionStoreStub.java changed 3.7% diff
streams/src/test/java/org/apache/kafka/test/StreamsTestUtils.java changed 14.6% diff
streams/test-utils/src/main/java/org/apache/kafka/streams/internals/QuietStreamsConfig.java moved 0.0%
streams/src/main/java/org/apache/kafka/streams/internals/QuietStreamsConfig.java
streams/test-utils/src/main/java/org/apache/kafka/streams/internals/WindowStoreFacade.java changed 0.7% diff
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java changed 3.1% diff
streams/test-utils/src/main/java/org/apache/kafka/streams/test/ConsumerRecordFactory.java changed 0.5% diff
streams/test-utils/src/main/java/org/apache/kafka/streams/test/OutputVerifier.java changed 0.8% diff
streams/test-utils/src/main/java/org/apache/kafka/streams/test/TestRecord.java added
streams/test-utils/src/main/java/org/apache/kafka/streams/TestInputTopic.java added
streams/test-utils/src/main/java/org/apache/kafka/streams/TestOutputTopic.java added
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java changed 31.5% diff
streams/test-utils/src/test/java/org/apache/kafka/streams/internals/WindowStoreFacadeTest.java changed 0.8% diff
streams/test-utils/src/test/java/org/apache/kafka/streams/test/ConsumerRecordFactoryTest.java changed 0.1% diff
streams/test-utils/src/test/java/org/apache/kafka/streams/test/OutputVerifierTest.java changed 0.1% diff
streams/test-utils/src/test/java/org/apache/kafka/streams/test/TestRecordTest.java added
streams/test-utils/src/test/java/org/apache/kafka/streams/TestTopicsTest.java added
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java changed 25.5% diff
streams/upgrade-system-tests-0100/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCoop
erativeRebalanceTest.java
added
streams/upgrade-system-tests-0101/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCoop
erativeRebalanceTest.java
added
streams/upgrade-system-tests-0102/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCoop
erativeRebalanceTest.java
added
streams/upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCoop
erativeRebalanceTest.java
added
streams/upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooper
ativeRebalanceTest.java
added
streams/upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooper
ativeRebalanceTest.java
added
streams/upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooper
ativeRebalanceTest.java
added
streams/upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooper
ativeRebalanceTest.java
added
streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooper
ativeRebalanceTest.java
added
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
added
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooper
ativeRebalanceTest.java
added
tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java changed 1.0% diff
tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java changed 2.4% diff
tools/src/main/java/org/apache/kafka/trogdor/common/WorkerUtils.java changed 5.3% diff
tools/src/main/java/org/apache/kafka/trogdor/fault/DegradedNetworkFaultSpec.java added
tools/src/main/java/org/apache/kafka/trogdor/fault/DegradedNetworkFaultWorker.java added
tools/src/main/java/org/apache/kafka/trogdor/rest/JsonRestServer.java changed 9.2% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressWorker.java changed 1.0% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ExternalCommandWorker.java changed 0.4% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/PayloadGenerator.java changed 8.9% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchSpec.java changed 9.9% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java changed 5.1% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/RandomComponent.java added
tools/src/main/java/org/apache/kafka/trogdor/workload/RandomComponentPayloadGenerator.java added
tools/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionSpec.java added
tools/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionWorker.java added
tools/src/test/java/org/apache/kafka/trogdor/common/JsonSerializationTest.java changed 2.6% diff
tools/src/test/java/org/apache/kafka/trogdor/common/WorkerUtilsTest.java changed 9.5% diff
tools/src/test/java/org/apache/kafka/trogdor/workload/ExternalCommandWorkerTest.java changed 4.8% diff
tools/src/test/java/org/apache/kafka/trogdor/workload/PayloadGeneratorTest.java changed 73.5% diff

Python Programs (41 of 137):

NameStatusDeltaVisual Diff
kafka-merge-pr.py changed 0.4% diff
tests/bin/external_trogdor_command_example.py changed 28.1% diff
tests/kafkatest/__init__.py changed 2.1% diff
tests/kafkatest/services/console_consumer.py changed 1.1% diff
tests/kafkatest/services/consumer_property.py added
tests/kafkatest/services/kafka/kafka.py changed 24.4% diff
tests/kafkatest/services/monitor/jmx.py changed 6.1% diff
tests/kafkatest/services/security/listener_security_config.py added
tests/kafkatest/services/security/security_config.py changed 8.0% diff
tests/kafkatest/services/streams.py changed 24.3% diff
tests/kafkatest/services/transactional_message_copier.py changed 1.3% diff
tests/kafkatest/services/trogdor/degraded_network_fault_spec.py added
tests/kafkatest/services/trogdor/trogdor.py changed 9.0% diff
tests/kafkatest/services/zookeeper.py changed 1.5% diff
tests/kafkatest/tests/client/client_compatibility_features_test.py changed 9.2% diff
tests/kafkatest/tests/client/client_compatibility_produce_consume_test.py changed 5.5% diff
tests/kafkatest/tests/connect/connect_distributed_test.py changed 5.3% diff
tests/kafkatest/tests/connect/connect_rest_test.py changed 3.4% diff
tests/kafkatest/tests/core/compatibility_test_new_broker_test.py changed 5.8% diff
tests/kafkatest/tests/core/fetch_from_follower_test.py added
tests/kafkatest/tests/core/network_degrade_test.py added
tests/kafkatest/tests/core/replica_scale_test.py added
tests/kafkatest/tests/core/round_trip_fault_test.py changed 12.6% diff
tests/kafkatest/tests/core/security_rolling_upgrade_test.py changed 52.0% diff
tests/kafkatest/tests/core/upgrade_test.py changed 8.4% diff
tests/kafkatest/tests/core/zookeeper_security_upgrade_test.py changed 1.8% diff
tests/kafkatest/tests/produce_consume_validate.py changed 5.5% diff
tests/kafkatest/tests/streams/streams_broker_bounce_test.py changed 4.5% diff
tests/kafkatest/tests/streams/streams_broker_compatibility_test.py changed 6.3% diff
tests/kafkatest/tests/streams/streams_cooperative_rebalance_upgrade_test.py added
tests/kafkatest/tests/streams/streams_eos_test.py changed 3.2% diff
tests/kafkatest/tests/streams/streams_multiple_rolling_upgrade_test.py changed 6.5% diff
tests/kafkatest/tests/streams/streams_named_repartition_topic_test.py changed 25.2% diff
tests/kafkatest/tests/streams/streams_optimized_test.py changed 10.4% diff
tests/kafkatest/tests/streams/streams_static_membership_test.py added
tests/kafkatest/tests/streams/streams_upgrade_test.py changed 9.9% diff
tests/kafkatest/tests/streams/utils/__init__.py added
tests/kafkatest/tests/streams/utils/util.py added
tests/kafkatest/utils/util.py changed 15.5% diff
tests/kafkatest/version.py changed 8.4% diff
tests/setup.py changed 3.2% diff

Shell Programs (7 of 46):

NameStatusDeltaVisual Diff
bin/connect-mirror-maker.sh added
bin/kafka-leader-election.sh added
bin/kafka-run-class.sh changed 9.1% diff
tests/bin/flatten_html.sh added
tests/docker/ducker-ak changed 4.5% diff
vagrant/aws/aws-init.sh changed 1.6% diff
vagrant/base.sh changed 7.9% diff

JavaScript Files (all 1):

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

JSON Files (101 of 107):

NameStatusDeltaVisual Diff
clients/src/main/resources/common/message/AddOffsetsToTxnRequest.json changed 2.0% diff
clients/src/main/resources/common/message/AddOffsetsToTxnResponse.json changed 2.3% diff
clients/src/main/resources/common/message/AddPartitionsToTxnRequest.json changed 1.7% diff
clients/src/main/resources/common/message/AddPartitionsToTxnResponse.json changed 1.6% diff
clients/src/main/resources/common/message/AlterConfigsRequest.json changed 1.6% diff
clients/src/main/resources/common/message/AlterConfigsResponse.json changed 6.3% diff
clients/src/main/resources/common/message/AlterPartitionReassignmentsRequest.json added
clients/src/main/resources/common/message/AlterPartitionReassignmentsResponse.json added
clients/src/main/resources/common/message/AlterReplicaLogDirsRequest.json changed 1.9% diff
clients/src/main/resources/common/message/AlterReplicaLogDirsResponse.json changed 1.6% diff
clients/src/main/resources/common/message/ApiVersionsRequest.json changed 40.9% diff
clients/src/main/resources/common/message/ApiVersionsResponse.json changed 28.1% diff
clients/src/main/resources/common/message/ControlledShutdownRequest.json changed 3.8% diff
clients/src/main/resources/common/message/ControlledShutdownResponse.json changed 3.7% diff
clients/src/main/resources/common/message/CreateAclsRequest.json changed 1.6% diff
clients/src/main/resources/common/message/CreateAclsResponse.json changed 1.8% diff
clients/src/main/resources/common/message/CreateDelegationTokenRequest.json changed 6.8% diff
clients/src/main/resources/common/message/CreateDelegationTokenResponse.json changed 4.9% diff
clients/src/main/resources/common/message/CreatePartitionsRequest.json changed 1.5% diff
clients/src/main/resources/common/message/CreatePartitionsResponse.json changed 1.7% diff
clients/src/main/resources/common/message/CreateTopicsRequest.json changed 22.1% diff
clients/src/main/resources/common/message/CreateTopicsResponse.json changed 87.0% diff
clients/src/main/resources/common/message/DeleteAclsRequest.json changed 1.5% diff
clients/src/main/resources/common/message/DeleteAclsResponse.json changed 1.0% diff
clients/src/main/resources/common/message/DeleteGroupsRequest.json changed 9.8% diff
clients/src/main/resources/common/message/DeleteGroupsResponse.json changed 6.5% diff
clients/src/main/resources/common/message/DeleteRecordsRequest.json changed 1.7% diff
clients/src/main/resources/common/message/DeleteRecordsResponse.json changed 1.5% diff
clients/src/main/resources/common/message/DeleteTopicsRequest.json changed 8.5% diff
clients/src/main/resources/common/message/DeleteTopicsResponse.json changed 6.5% diff
clients/src/main/resources/common/message/DescribeAclsRequest.json changed 1.6% diff
clients/src/main/resources/common/message/DescribeAclsResponse.json changed 1.2% diff
clients/src/main/resources/common/message/DescribeConfigsRequest.json changed 1.8% diff
clients/src/main/resources/common/message/DescribeConfigsResponse.json changed 0.8% diff
clients/src/main/resources/common/message/DescribeDelegationTokenRequest.json changed 2.2% diff
clients/src/main/resources/common/message/DescribeDelegationTokenResponse.json changed 1.1% diff
clients/src/main/resources/common/message/DescribeGroupsRequest.json changed 15.7% diff
clients/src/main/resources/common/message/DescribeGroupsResponse.json changed 12.2% diff
clients/src/main/resources/common/message/DescribeLogDirsRequest.json changed 2.2% diff
clients/src/main/resources/common/message/DescribeLogDirsResponse.json changed 1.1% diff
clients/src/main/resources/common/message/ElectPreferredLeadersRequest.json renamed 40.4% diff
clients/src/main/resources/common/message/ElectLeadersRequest.json
clients/src/main/resources/common/message/ElectPreferredLeadersResponse.json renamed 15.4% diff
clients/src/main/resources/common/message/ElectLeadersResponse.json
clients/src/main/resources/common/message/EndTxnRequest.json changed 2.1% diff
clients/src/main/resources/common/message/EndTxnResponse.json changed 2.3% diff
clients/src/main/resources/common/message/ExpireDelegationTokenRequest.json changed 2.5% diff
clients/src/main/resources/common/message/ExpireDelegationTokenResponse.json changed 2.0% diff
clients/src/main/resources/common/message/FetchRequest.json changed 2.5% diff
clients/src/main/resources/common/message/FetchResponse.json changed 0.7% diff
clients/src/main/resources/common/message/FindCoordinatorRequest.json changed 8.9% diff
clients/src/main/resources/common/message/FindCoordinatorResponse.json changed 5.8% diff
clients/src/main/resources/common/message/HeartbeatRequest.json changed 6.9% diff
clients/src/main/resources/common/message/HeartbeatResponse.json changed 7.6% diff
clients/src/main/resources/common/message/IncrementalAlterConfigsRequest.json changed 4.9% diff
clients/src/main/resources/common/message/IncrementalAlterConfigsResponse.json changed 10.5% diff
clients/src/main/resources/common/message/InitProducerIdRequest.json changed 7.6% diff
clients/src/main/resources/common/message/InitProducerIdResponse.json changed 6.4% diff
clients/src/main/resources/common/message/JoinGroupRequest.json changed 4.3% diff
clients/src/main/resources/common/message/JoinGroupResponse.json changed 4.7% diff
clients/src/main/resources/common/message/LeaderAndIsrRequest.json changed 58.5% diff
clients/src/main/resources/common/message/LeaderAndIsrResponse.json changed 11.6% diff
clients/src/main/resources/common/message/LeaveGroupRequest.json changed 65.3% diff
clients/src/main/resources/common/message/LeaveGroupResponse.json changed 60.0% diff
clients/src/main/resources/common/message/ListGroupsRequest.json changed 11.2% diff
clients/src/main/resources/common/message/ListGroupsResponse.json changed 6.3% diff
clients/src/main/resources/common/message/ListOffsetRequest.json changed 1.7% diff
clients/src/main/resources/common/message/ListOffsetResponse.json changed 1.8% diff
clients/src/main/resources/common/message/ListPartitionReassignmentsRequest.json added
clients/src/main/resources/common/message/ListPartitionReassignmentsResponse.json added
clients/src/main/resources/common/message/MetadataRequest.json changed 5.3% diff
clients/src/main/resources/common/message/MetadataResponse.json changed 2.2% diff
clients/src/main/resources/common/message/OffsetCommitRequest.json changed 3.2% diff
clients/src/main/resources/common/message/OffsetCommitResponse.json changed 5.0% diff
clients/src/main/resources/common/message/OffsetDeleteRequest.json added
clients/src/main/resources/common/message/OffsetDeleteResponse.json added
clients/src/main/resources/common/message/OffsetFetchRequest.json changed 15.5% diff
clients/src/main/resources/common/message/OffsetFetchResponse.json changed 7.5% diff
clients/src/main/resources/common/message/OffsetForLeaderEpochRequest.json changed 1.6% diff
clients/src/main/resources/common/message/OffsetForLeaderEpochResponse.json changed 1.4% diff
clients/src/main/resources/common/message/ProduceRequest.json changed 5.4% diff
clients/src/main/resources/common/message/ProduceResponse.json changed 40.8% diff
clients/src/main/resources/common/message/RenewDelegationTokenRequest.json changed 2.6% diff
clients/src/main/resources/common/message/RenewDelegationTokenResponse.json changed 2.0% diff
clients/src/main/resources/common/message/RequestHeader.json changed 61.6% diff
clients/src/main/resources/common/message/ResponseHeader.json changed 10.1% diff
clients/src/main/resources/common/message/SaslAuthenticateRequest.json changed 2.8% diff
clients/src/main/resources/common/message/SaslAuthenticateResponse.json changed 1.9% diff
clients/src/main/resources/common/message/SaslHandshakeRequest.json changed 2.9% diff
clients/src/main/resources/common/message/SaslHandshakeResponse.json changed 2.6% diff
clients/src/main/resources/common/message/StopReplicaRequest.json changed 9.6% diff
clients/src/main/resources/common/message/StopReplicaResponse.json changed 8.9% diff
clients/src/main/resources/common/message/SyncGroupRequest.json changed 5.5% diff
clients/src/main/resources/common/message/SyncGroupResponse.json changed 7.1% diff
clients/src/main/resources/common/message/TxnOffsetCommitRequest.json changed 1.2% diff
clients/src/main/resources/common/message/TxnOffsetCommitResponse.json changed 1.6% diff
clients/src/main/resources/common/message/UpdateMetadataRequest.json changed 53.4% diff
clients/src/main/resources/common/message/UpdateMetadataResponse.json changed 5.1% diff
clients/src/main/resources/common/message/WriteTxnMarkersRequest.json changed 1.4% diff
clients/src/main/resources/common/message/WriteTxnMarkersResponse.json changed 1.6% diff
clients/src/test/resources/common/message/SimpleExampleMessage.json added

XML Documents (7 of 10):

NameStatusDeltaVisual Diff
checkstyle/import-control-jmh-benchmarks.xml added
checkstyle/import-control.xml changed 7.5% diff
checkstyle/suppressions.xml changed 33.6% diff
gradle/spotbugs-exclude.xml changed 8.7% 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 (3 of 27):

NameStatusDeltaVisual Diff
bin/windows/kafka-leader-election.bat added
bin/windows/kafka-run-class.bat changed 0.6% diff
bin/windows/kafka-streams-application-reset.bat added

Git Files (1 of 8):

NameStatusDeltaVisual Diff
.gitignore changed 4.9% diff

HTML Pages (19 of 59):

NameStatusDeltaVisual Diff
docs/api.html changed 0.02%
docs/configuration.html changed 0.01%
docs/documentation.html changed 1.0%
docs/ops.html changed 11.1%
docs/protocol.html changed 5.2%
docs/security.html changed 0.1%
docs/streams/core-concepts.html changed 0.4%
docs/streams/developer-guide/config-streams.html changed 0.001%
docs/streams/developer-guide/dsl-api.html changed 6.0%
docs/streams/developer-guide/dsl-topology-naming.html added
docs/streams/developer-guide/memory-mgmt.html changed 0.003%
docs/streams/developer-guide/processor-api.html changed 0.1%
docs/streams/developer-guide/testing.html changed 0.005%
docs/streams/quickstart.html changed 0.3%
docs/streams/tutorial.html changed 0.02%
docs/streams/upgrade-guide.html changed 12.0%
docs/toc.html changed 0.01%
docs/upgrade.html changed 10.9%
docs/uses.html changed 0.02%

Property Files (14 of 45):

NameStatusDeltaVisual Diff
config/connect-log4j.properties changed 59.7% diff
config/connect-mirror-maker.properties added
config/log4j.properties changed 2.3% diff
config/server.properties changed 1.8% diff
config/zookeeper.properties changed 41.0% diff
connect/mirror/src/test/resources/log4j.properties added
core/src/test/resources/log4j.properties changed 4.0% diff
gradle.properties changed 3.4% diff
gradle/wrapper/gradle-wrapper.properties added
streams/src/test/resources/kafka/kafka-streams-version.properties added
tests/kafkatest/services/kafka/templates/kafka.properties changed 46.4% diff
tests/kafkatest/services/kafka/templates/log4j.properties changed 1.4% diff
tests/kafkatest/services/templates/connect_log4j.properties changed 3.2% diff
tests/kafkatest/tests/connect/templates/connect-distributed.properties changed 2.2% diff

Directories (59 of 773):

NameStatus
clients/src/main/java/org/apache/kafka/common/replica added
clients/src/main/java/org/apache/kafka/server/authorizer added
clients/src/test/java/org/apache/kafka/common/replica added
clients/src/test/resources/common added
clients/src/test/resources/common/message added
connect/mirror added
connect/mirror-client added
connect/mirror-client/src added
connect/mirror-client/src/main added
connect/mirror-client/src/main/java added
connect/mirror-client/src/main/java/org added
connect/mirror-client/src/main/java/org/apache added
connect/mirror-client/src/main/java/org/apache/kafka added
connect/mirror-client/src/main/java/org/apache/kafka/connect added
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror added
connect/mirror-client/src/test added
connect/mirror-client/src/test/java added
connect/mirror-client/src/test/java/org added
connect/mirror-client/src/test/java/org/apache added
connect/mirror-client/src/test/java/org/apache/kafka added
connect/mirror-client/src/test/java/org/apache/kafka/connect added
connect/mirror-client/src/test/java/org/apache/kafka/connect/mirror added
connect/mirror/src added
connect/mirror/src/main added
connect/mirror/src/main/java added
connect/mirror/src/main/java/org added
connect/mirror/src/main/java/org/apache added
connect/mirror/src/main/java/org/apache/kafka added
connect/mirror/src/main/java/org/apache/kafka/connect added
connect/mirror/src/main/java/org/apache/kafka/connect/mirror added
connect/mirror/src/test added
connect/mirror/src/test/java added
connect/mirror/src/test/java/org added
connect/mirror/src/test/java/org/apache added
connect/mirror/src/test/java/org/apache/kafka added
connect/mirror/src/test/java/org/apache/kafka/connect added
connect/mirror/src/test/java/org/apache/kafka/connect/mirror added
connect/mirror/src/test/resources added
core/src/main/scala/kafka/security/authorizer added
core/src/test/scala/unit/kafka/security/authorizer added
gradle/wrapper added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition added
streams/examples/src/test/java/org/apache/kafka/streams/examples/docs added
streams/src/main/java/org/apache/kafka/streams/internals/metrics added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin added
streams/src/test/java/org/apache/kafka/streams/internals/metrics added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin added
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics added
streams/src/test/resources/kafka added
streams/upgrade-system-tests-23 added
streams/upgrade-system-tests-23/src added
streams/upgrade-system-tests-23/src/test added
streams/upgrade-system-tests-23/src/test/java added
streams/upgrade-system-tests-23/src/test/java/org added
streams/upgrade-system-tests-23/src/test/java/org/apache added
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka added
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams added
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests added
tests/kafkatest/tests/streams/utils added

Readme Files (4 of 7):

NameStatusDeltaVisual Diff
clients/src/main/resources/common/message/README.md changed 16.8% diff
connect/mirror/README.md added
README.md changed 11.6% diff
tests/README.md changed 11.0% diff

Text Files (285 of 415):

NameStatusDeltaVisual Diff
build.gradle changed 11.1% diff
core/src/main/scala/kafka/admin/AdminClient.scala removed
core/src/main/scala/kafka/api/ApiUtils.scala changed 2.8% diff
core/src/main/scala/kafka/api/ApiVersion.scala changed 4.7% diff
core/src/main/scala/kafka/api/LeaderAndIsr.scala changed 5.8% diff
core/src/main/scala/kafka/api/package.scala added
core/src/main/scala/kafka/cluster/Broker.scala changed 46.2% diff
core/src/main/scala/kafka/cluster/EndPoint.scala changed 5.1% diff
core/src/main/scala/kafka/cluster/Partition.scala changed 56.0% diff
core/src/main/scala/kafka/cluster/Replica.scala changed 70.0% diff
core/src/main/scala/kafka/common/Config.scala changed 4.0% diff
core/src/main/scala/kafka/common/InconsistentBrokerMetadataException.scala added
core/src/main/scala/kafka/common/InconsistentClusterIdException.scala added
core/src/main/scala/kafka/common/InterBrokerSendThread.scala changed 0.5% diff
core/src/main/scala/kafka/common/KafkaException.scala changed 14.7% diff
core/src/main/scala/kafka/common/MessageFormatter.scala changed 5.2% diff
core/src/main/scala/kafka/common/MessageReader.scala changed 7.0% diff
core/src/main/scala/kafka/common/RecordValidationException.scala added
core/src/main/scala/kafka/common/TopicAndPartition.scala removed
core/src/main/scala/kafka/controller/ControllerChannelManager.scala changed 18.2% diff
core/src/main/scala/kafka/controller/ControllerState.scala changed 16.3% diff
core/src/main/scala/kafka/controller/Election.scala changed 41.7% diff
core/src/main/scala/kafka/controller/KafkaController.scala changed 42.3% diff
core/src/main/scala/kafka/controller/PartitionStateMachine.scala changed 38.6% diff
core/src/main/scala/kafka/controller/ReplicaStateMachine.scala changed 24.4% diff
core/src/main/scala/kafka/controller/TopicDeletionManager.scala changed 3.0% diff
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala changed 24.6% diff
core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala changed 15.0% diff
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala changed 5.3% diff
core/src/main/scala/kafka/coordinator/group/MemberMetadata.scala changed 0.9% diff
core/src/main/scala/kafka/coordinator/transaction/ProducerIdManager.scala changed 0.4% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala changed 1.6% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala changed 1.0% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala changed 0.7% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala changed 5.2% diff
core/src/main/scala/kafka/log/AbstractIndex.scala changed 3.6% diff
core/src/main/scala/kafka/log/LazyIndex.scala added
core/src/main/scala/kafka/log/Log.scala changed 16.7% diff
core/src/main/scala/kafka/log/LogCleaner.scala changed 8.5% diff
core/src/main/scala/kafka/log/LogCleanerManager.scala changed 15.5% diff
core/src/main/scala/kafka/log/LogManager.scala changed 14.5% diff
core/src/main/scala/kafka/log/LogSegment.scala changed 9.0% diff
core/src/main/scala/kafka/log/LogValidator.scala changed 65.0% diff
core/src/main/scala/kafka/log/OffsetIndex.scala changed 13.9% diff
core/src/main/scala/kafka/log/OffsetMap.scala changed 4.3% diff
core/src/main/scala/kafka/log/ProducerStateManager.scala changed 9.7% diff
core/src/main/scala/kafka/log/TimeIndex.scala changed 11.7% diff
core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala changed 6.0% diff
core/src/main/scala/kafka/metrics/KafkaMetricsReporter.scala changed 5.7% diff
core/src/main/scala/kafka/network/SocketServer.scala changed 6.5% diff
core/src/main/scala/kafka/security/auth/Authorizer.scala changed 1.2% diff
core/src/main/scala/kafka/security/auth/SimpleAclAuthorizer.scala changed 85.3% diff
core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala added
core/src/main/scala/kafka/security/authorizer/AuthorizerUtils.scala added
core/src/main/scala/kafka/security/authorizer/AuthorizerWrapper.scala added
core/src/main/scala/kafka/security/CredentialProvider.scala changed 3.3% diff
core/src/main/scala/kafka/security/SecurityUtils.scala removed
core/src/main/scala/kafka/server/AbstractFetcherManager.scala changed 7.2% diff
core/src/main/scala/kafka/server/AbstractFetcherThread.scala changed 2.9% diff
core/src/main/scala/kafka/server/AdminManager.scala changed 24.8% diff
core/src/main/scala/kafka/server/BrokerMetadataCheckpoint.scala changed 16.7% diff
core/src/main/scala/kafka/server/BrokerStates.scala changed 3.1% diff
core/src/main/scala/kafka/server/checkpoints/CheckpointFile.scala changed 1.0% diff
core/src/main/scala/kafka/server/checkpoints/LeaderEpochCheckpointFile.scala changed 2.0% diff
core/src/main/scala/kafka/server/checkpoints/OffsetCheckpointFile.scala changed 48.9% diff
core/src/main/scala/kafka/server/ClientQuotaManager.scala changed 1.7% diff
core/src/main/scala/kafka/server/ClientRequestQuotaManager.scala changed 1.2% diff
core/src/main/scala/kafka/server/ConfigHandler.scala changed 10.3% diff
core/src/main/scala/kafka/server/DelayedCreatePartitions.scala changed 3.7% diff
core/src/main/scala/kafka/server/DelayedDeleteRecords.scala changed 16.8% diff
core/src/main/scala/kafka/server/DelayedDeleteTopics.scala changed 1.4% diff
core/src/main/scala/kafka/server/DelayedElectPreferredLeader.scala renamed 37.5% diff
core/src/main/scala/kafka/server/DelayedElectLeader.scala
core/src/main/scala/kafka/server/DelayedFetch.scala changed 29.8% diff
core/src/main/scala/kafka/server/DelayedFuture.scala added
core/src/main/scala/kafka/server/DelayedOperation.scala changed 5.0% diff
core/src/main/scala/kafka/server/DelayedOperationKey.scala changed 9.8% diff
core/src/main/scala/kafka/server/DelayedProduce.scala changed 11.8% diff
core/src/main/scala/kafka/server/DelegationTokenManager.scala changed 1.8% diff
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala changed 3.9% diff
core/src/main/scala/kafka/server/DynamicConfig.scala changed 1.8% diff
core/src/main/scala/kafka/server/DynamicConfigManager.scala changed 2.1% diff
core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala changed 4.3% diff
core/src/main/scala/kafka/server/FetchSession.scala changed 0.5% diff
core/src/main/scala/kafka/server/KafkaApis.scala changed 29.6% diff
core/src/main/scala/kafka/server/KafkaConfig.scala changed 3.1% diff
core/src/main/scala/kafka/server/KafkaRequestHandler.scala changed 67.8% diff
core/src/main/scala/kafka/server/KafkaServer.scala changed 15.9% diff
core/src/main/scala/kafka/server/KafkaServerStartable.scala changed 31.8% diff
core/src/main/scala/kafka/server/LogOffsetMetadata.scala changed 9.6% diff
core/src/main/scala/kafka/server/MetadataCache.scala changed 20.8% diff
core/src/main/scala/kafka/server/QuotaFactory.scala changed 0.6% diff
core/src/main/scala/kafka/server/ReplicaAlterLogDirsManager.scala changed 1.6% diff
core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala changed 12.1% diff
core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala changed 1.2% diff
core/src/main/scala/kafka/server/ReplicaFetcherManager.scala changed 1.4% diff
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala changed 8.9% diff
core/src/main/scala/kafka/server/ReplicaManager.scala changed 43.7% diff
core/src/main/scala/kafka/server/ReplicationQuotaManager.scala changed 5.0% diff
core/src/main/scala/kafka/tools/ZooKeeperMainWrapper.scala removed
core/src/main/scala/kafka/utils/CommandLineUtils.scala changed 9.7% diff
core/src/main/scala/kafka/utils/CoreUtils.scala changed 10.0% diff
core/src/main/scala/kafka/utils/FileLock.scala changed 2.1% diff
core/src/main/scala/kafka/utils/json/DecodeJson.scala changed 16.3% diff
core/src/main/scala/kafka/utils/KafkaScheduler.scala changed 12.4% diff
core/src/main/scala/kafka/utils/Log4jController.scala changed 78.7% diff
core/src/main/scala/kafka/utils/Pool.scala changed 3.4% diff
core/src/main/scala/kafka/utils/ReplicationUtils.scala changed 3.4% diff
core/src/main/scala/kafka/utils/ShutdownableThread.scala changed 17.3% diff
core/src/main/scala/kafka/utils/timer/Timer.scala changed 0.9% diff
core/src/main/scala/kafka/utils/VerifiableProperties.scala changed 0.3% diff
core/src/main/scala/kafka/utils/ZkUtils.scala removed
core/src/main/scala/kafka/zk/AdminZkClient.scala changed 6.5% diff
core/src/main/scala/kafka/zk/KafkaZkClient.scala changed 5.4% diff
core/src/main/scala/kafka/zk/ZkData.scala changed 9.8% diff
core/src/main/scala/kafka/zookeeper/ZooKeeperClient.scala changed 0.1% diff
core/src/test/scala/integration/kafka/admin/BrokerApiVersionsCommandTest.scala changed 3.0% diff
core/src/test/scala/integration/kafka/admin/ReassignPartitionsIntegrationTest.scala changed 1.9% diff
core/src/test/scala/integration/kafka/api/AbstractConsumerTest.scala changed 4.7% diff
core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala changed 52.6% diff
core/src/test/scala/integration/kafka/api/AdminClientWithPoliciesIntegrationTest.scala changed 1.6% diff
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala changed 44.4% diff
core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala changed 4.2% diff
core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala changed 5.5% diff
core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala changed 4.7% diff
core/src/test/scala/integration/kafka/api/ClientIdQuotaTest.scala changed 10.0% diff
core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala changed 8.8% diff
core/src/test/scala/integration/kafka/api/ConsumerTopicCreationTest.scala changed 3.8% diff
core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala changed 3.5% diff
core/src/test/scala/integration/kafka/api/DelegationTokenEndToEndAuthorizationTest.scala changed 3.3% diff
core/src/test/scala/integration/kafka/api/DescribeAuthorizedOperationsTest.scala changed 18.5% diff
core/src/test/scala/integration/kafka/api/EndToEndClusterIdTest.scala changed 4.8% diff
core/src/test/scala/integration/kafka/api/GroupCoordinatorIntegrationTest.scala changed 2.8% diff
core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala changed 4.7% diff
core/src/test/scala/integration/kafka/api/LegacyAdminClientTest.scala removed
core/src/test/scala/integration/kafka/api/LogAppendTimeTest.scala changed 2.3% diff
core/src/test/scala/integration/kafka/api/MetricsTest.scala changed 0.8% diff
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala changed 6.1% diff
core/src/test/scala/integration/kafka/api/PlaintextEndToEndAuthorizationTest.scala changed 1.9% diff
core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala changed 6.5% diff
core/src/test/scala/integration/kafka/api/ProducerCompressionTest.scala changed 2.6% diff
core/src/test/scala/integration/kafka/api/ProducerFailureHandlingTest.scala changed 6.1% diff
core/src/test/scala/integration/kafka/api/RackAwareAutoTopicCreationTest.scala changed 1.4% diff
core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala changed 7.9% diff
core/src/test/scala/integration/kafka/api/SaslEndToEndAuthorizationTest.scala changed 0.9% diff
core/src/test/scala/integration/kafka/api/SaslGssapiSslEndToEndAuthorizationTest.scala changed 7.0% diff
core/src/test/scala/integration/kafka/api/SaslMultiMechanismConsumerTest.scala changed 1.3% diff
core/src/test/scala/integration/kafka/api/SaslPlainPlaintextConsumerTest.scala changed 5.9% diff
core/src/test/scala/integration/kafka/api/SaslPlainSslEndToEndAuthorizationTest.scala changed 7.6% diff
core/src/test/scala/integration/kafka/api/SaslScramSslEndToEndAuthorizationTest.scala changed 4.5% diff
core/src/test/scala/integration/kafka/api/SaslSetup.scala changed 3.1% diff
core/src/test/scala/integration/kafka/api/SaslSslAdminClientIntegrationTest.scala changed 24.3% diff
core/src/test/scala/integration/kafka/api/SslAdminClientIntegrationTest.scala added
core/src/test/scala/integration/kafka/api/SslEndToEndAuthorizationTest.scala changed 1.0% diff
core/src/test/scala/integration/kafka/api/TransactionsBounceTest.scala changed 0.9% diff
core/src/test/scala/integration/kafka/api/TransactionsTest.scala changed 0.7% diff
core/src/test/scala/integration/kafka/api/UserClientIdQuotaTest.scala changed 7.9% diff
core/src/test/scala/integration/kafka/api/UserQuotaTest.scala changed 7.9% diff
core/src/test/scala/integration/kafka/network/DynamicConnectionQuotaTest.scala changed 3.3% diff
core/src/test/scala/integration/kafka/server/DelayedFetchTest.scala changed 100.0% diff
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala changed 11.5% diff
core/src/test/scala/integration/kafka/server/GssapiAuthenticationTest.scala changed 0.4% diff
core/src/test/scala/integration/kafka/server/MultipleListenersWithAdditionalJaasContextTest.scala changed 1.7% diff
core/src/test/scala/integration/kafka/server/MultipleListenersWithDefaultJaasContextTest.scala changed 2.3% diff
core/src/test/scala/integration/kafka/server/MultipleListenersWithSameSecurityProtocolBaseTest.scal
a
changed 0.8% diff
core/src/test/scala/integration/kafka/server/ScramServerStartupTest.scala changed 2.3% diff
core/src/test/scala/integration/kafka/tools/MirrorMakerIntegrationTest.scala changed 0.6% diff
core/src/test/scala/kafka/security/minikdc/MiniKdc.scala changed 3.2% diff
core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala changed 9.8% diff
core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala changed 11.6% diff
core/src/test/scala/unit/kafka/admin/AdminTest.scala removed
core/src/test/scala/unit/kafka/admin/ConsumerGroupCommandTest.scala changed 26.4% diff
core/src/test/scala/unit/kafka/admin/DelegationTokenCommandTest.scala changed 3.3% diff
core/src/test/scala/unit/kafka/admin/DeleteConsumerGroupsTest.scala changed 12.3% diff
core/src/test/scala/unit/kafka/admin/DeleteOffsetsConsumerGroupCommandIntegrationTest.scala added
core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala changed 6.0% diff
core/src/test/scala/unit/kafka/admin/DescribeConsumerGroupTest.scala changed 14.2% diff
core/src/test/scala/unit/kafka/admin/ListConsumerGroupTest.scala changed 10.4% diff
core/src/test/scala/unit/kafka/admin/PreferredReplicaElectionCommandTest.scala removed
core/src/test/scala/unit/kafka/admin/PreferredReplicaLeaderElectionCommandTest.scala changed 45.0% diff
core/src/test/scala/unit/kafka/admin/RackAwareTest.scala changed 2.2% diff
core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala changed 100.0% diff
core/src/test/scala/unit/kafka/admin/ReassignPartitionsCommandTest.scala changed 3.2% diff
core/src/test/scala/unit/kafka/admin/TestAdminUtils.scala removed
core/src/test/scala/unit/kafka/admin/TopicCommandTest.scala changed 3.8% diff
core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala changed 13.7% diff
core/src/test/scala/unit/kafka/common/ZkNodeChangeNotificationListenerTest.scala changed 4.8% diff
core/src/test/scala/unit/kafka/controller/ControllerFailoverTest.scala changed 2.3% diff
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala changed 9.4% diff
core/src/test/scala/unit/kafka/controller/MockPartitionStateMachine.scala changed 46.1% diff
core/src/test/scala/unit/kafka/controller/MockReplicaStateMachine.scala changed 1.7% diff
core/src/test/scala/unit/kafka/coordinator/AbstractCoordinatorConcurrencyTest.scala changed 7.1% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorConcurrencyTest.scala changed 11.0% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorConcurrencyTest.scala changed 3.5% diff
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala changed 4.7% diff
core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala changed 2.6% diff
core/src/test/scala/unit/kafka/integration/MinIsrConfigTest.scala changed 3.2% diff
core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala changed 2.7% diff
core/src/test/scala/unit/kafka/log/BrokerCompressionTest.scala changed 7.7% diff
core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala changed 26.0% diff
core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala changed 21.0% diff
core/src/test/scala/unit/kafka/log/LogCleanerParameterizedIntegrationTest.scala changed 4.3% diff
core/src/test/scala/unit/kafka/log/LogUtils.scala changed 12.4% diff
core/src/test/scala/unit/kafka/log/TransactionIndexTest.scala changed 0.6% diff
core/src/test/scala/unit/kafka/metrics/MetricsTest.scala changed 38.4% diff
core/src/test/scala/unit/kafka/security/auth/AclTest.scala changed 2.1% diff
core/src/test/scala/unit/kafka/security/auth/SimpleAclAuthorizerTest.scala changed 6.2% diff
core/src/test/scala/unit/kafka/security/auth/ZkAuthorizationTest.scala changed 2.0% diff
core/src/test/scala/unit/kafka/security/authorizer/AclAuthorizerTest.scala added
core/src/test/scala/unit/kafka/security/token/delegation/DelegationTokenManagerTest.scala changed 17.6% diff
core/src/test/scala/unit/kafka/server/AbstractCreateTopicsRequestTest.scala changed 8.4% diff
core/src/test/scala/unit/kafka/server/AdvertiseBrokerTest.scala changed 1.0% diff
core/src/test/scala/unit/kafka/server/AlterReplicaLogDirsRequestTest.scala changed 0.8% diff
core/src/test/scala/unit/kafka/server/ApiVersionsRequestTest.scala changed 73.2% diff
core/src/test/scala/unit/kafka/server/BaseRequestTest.scala changed 15.5% diff
core/src/test/scala/unit/kafka/server/BrokerEpochIntegrationTest.scala changed 22.6% diff
core/src/test/scala/unit/kafka/server/checkpoints/OffsetCheckpointFileTest.scala changed 41.7% diff
core/src/test/scala/unit/kafka/server/CreateTopicsRequestTest.scala changed 11.0% diff
core/src/test/scala/unit/kafka/server/CreateTopicsRequestWithPolicyTest.scala changed 8.2% diff
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsOnPlainTextTest.scala changed 3.9% diff
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsTest.scala changed 2.9% diff
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsWithDisableTokenFeatureTest.scala changed 3.2% diff
core/src/test/scala/unit/kafka/server/DeleteTopicsRequestTest.scala changed 2.3% diff
core/src/test/scala/unit/kafka/server/DeleteTopicsRequestWithDeletionDisabledTest.scala changed 1.6% diff
core/src/test/scala/unit/kafka/server/DescribeLogDirsRequestTest.scala changed 5.4% diff
core/src/test/scala/unit/kafka/server/DynamicConfigChangeTest.scala changed 5.4% diff
core/src/test/scala/unit/kafka/server/DynamicConfigTest.scala changed 12.0% diff
core/src/test/scala/unit/kafka/server/EdgeCaseRequestTest.scala changed 9.9% 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 4.8% diff
core/src/test/scala/unit/kafka/server/epoch/util/ReplicaFetcherMockBlockingSend.scala changed 1.6% diff
core/src/test/scala/unit/kafka/server/FetchRequestTest.scala changed 1.9% diff
core/src/test/scala/unit/kafka/server/KafkaMetricReporterClusterIdTest.scala changed 7.7% diff
core/src/test/scala/unit/kafka/server/KafkaMetricReporterExceptionHandlingTest.scala changed 25.5% diff
core/src/test/scala/unit/kafka/server/KafkaServerTest.scala changed 3.3% diff
core/src/test/scala/unit/kafka/server/LeaderElectionTest.scala changed 13.1% diff
core/src/test/scala/unit/kafka/server/LogDirFailureTest.scala changed 35.7% diff
core/src/test/scala/unit/kafka/server/LogOffsetTest.scala changed 4.1% diff
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala changed 8.3% diff
core/src/test/scala/unit/kafka/server/MetadataRequestTest.scala changed 2.7% diff
core/src/test/scala/unit/kafka/server/ProduceRequestTest.scala changed 30.9% diff
core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala changed 4.9% diff
core/src/test/scala/unit/kafka/server/ReplicationQuotasTest.scala changed 0.4% diff
core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala changed 24.9% diff
core/src/test/scala/unit/kafka/server/SaslApiVersionsRequestTest.scala changed 11.5% diff
core/src/test/scala/unit/kafka/server/ServerGenerateBrokerIdTest.scala changed 18.7% diff
core/src/test/scala/unit/kafka/server/ServerGenerateClusterIdTest.scala changed 87.8% diff
core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala changed 5.8% diff
core/src/test/scala/unit/kafka/server/ServerStartupTest.scala changed 0.8% diff
core/src/test/scala/unit/kafka/server/StopReplicaRequestTest.scala changed 21.2% diff
core/src/test/scala/unit/kafka/utils/CoreUtilsTest.scala changed 4.3% diff
core/src/test/scala/unit/kafka/utils/JaasTestUtils.scala changed 1.9% diff
core/src/test/scala/unit/kafka/utils/LogCaptureAppender.scala changed 1.8% diff
core/src/test/scala/unit/kafka/utils/MockScheduler.scala changed 39.5% diff
core/src/test/scala/unit/kafka/utils/MockTime.scala changed 2.7% diff
core/src/test/scala/unit/kafka/utils/ReplicationUtilsTest.scala changed 1.9% diff
core/src/test/scala/unit/kafka/utils/TestUtils.scala changed 21.3% diff
core/src/test/scala/unit/kafka/utils/timer/MockTimer.scala changed 2.2% diff
core/src/test/scala/unit/kafka/utils/ZkUtilsTest.scala removed
core/src/test/scala/unit/kafka/zk/AdminZkClientTest.scala changed 7.6% diff
core/src/test/scala/unit/kafka/zk/EmbeddedZookeeper.scala changed 5.0% diff
core/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala changed 6.4% diff
core/src/test/scala/unit/kafka/zk/ZkFourLetterWords.scala changed 3.5% diff
core/src/test/scala/unit/kafka/zk/ZooKeeperTestHarness.scala changed 3.4% diff
core/src/test/scala/unit/kafka/zookeeper/ZooKeeperClientTest.scala changed 0.9% diff
gradle/dependencies.gradle changed 25.1% diff
gradlew added
settings.gradle changed 6.0% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionsCompatConversions.scal
a
changed 4.9% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/ImplicitConversions.scala changed 8.9% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KGroupedStream.scala changed 2.7% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala changed 7.5% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KTable.scala changed 13.8% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/package.scala changed 6.8% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/StreamJoined.scala added
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala changed 9.1% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala changed 38.1% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KTableTest.scala changed 36.9% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/StreamJoinedTest.scala added
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinScalaIntegrati
onTestImplicitSerdes.scala
changed 1.0% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/utils/TestDriver.scala changed 41.6% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/WordCountTest.scala changed 1.9% diff
tests/docker/Dockerfile changed 15.1% diff
TROGDOR.md changed 36.4% diff
wrapper.gradle changed 100.0% diff

Packages Compared:

kafka-2.3.1-src.tgz
kafka-2.4.0-src.tgz


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