"Fossies" - the Fresh Open Source Software Archive  

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

About: Apache kafka is a distributed streaming platform.

Summary:

The "kafka" source code changed by about 12.5% and now consists of 3626 regular files (+106) and 816 directories (+18).

Related Informations:

None found by Fossies.

Changes In Files (According File Type):

File TypeTotalAddedRemovedChanged
C program 117 5 1 77
Java program 2580 122 26 685
Python program 141 0 3 46
Shell program 47 0 1 11
Ruby program 1 0 0 0
Configuration file 7 0 0 0
JavaScript file 1 0 0 1
JSON file 111 5 1 17
XML document 10 0 0 8
DOS Batch file 27 0 0 1
Git file 8 0 0 1
HTML page 61 0 0 21
Log file 36 1 0 25
Property file 47 0 0 5
RDF file 1 0 0 0
XML style sheet 1 0 0 0
YAML file 2 1 0 0
Image file 49 0 0 0
Directory 819 21 3 0
Information file 3 0 0 0
License 1 0 0 1
Readme file 7 0 0 3
Text file 403 9 5 200
Other 2 0 0 0
Total Files4482164401102



C Programs (83 of 117):

NameStatusDeltaVisual Diff
core/src/main/scala/kafka/admin/AclCommand.scala changed 4.1% diff
core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala changed 1.5% diff
core/src/main/scala/kafka/admin/ConfigCommand.scala changed 25.3% diff
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala changed 13.2% diff
core/src/main/scala/kafka/admin/DelegationTokenCommand.scala changed 0.4% diff
core/src/main/scala/kafka/admin/DeleteRecordsCommand.scala changed 2.3% diff
core/src/main/scala/kafka/admin/LeaderElectionCommand.scala changed 0.4% diff
core/src/main/scala/kafka/admin/LogDirsCommand.scala changed 2.6% diff
core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala changed 0.3% diff
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala changed 100.0% diff
core/src/main/scala/kafka/admin/TopicCommand.scala changed 13.5% diff
core/src/main/scala/kafka/admin/ZkSecurityMigrator.scala changed 1.7% diff
core/src/main/scala/kafka/controller/ControllerContext.scala changed 9.3% diff
core/src/main/scala/kafka/network/RequestChannel.scala changed 19.6% diff
core/src/main/scala/kafka/tools/ConsoleConsumer.scala changed 0.4% diff
core/src/main/scala/kafka/tools/ConsoleProducer.scala changed 1.5% diff
core/src/main/scala/kafka/tools/ConsumerPerformance.scala changed 0.7% diff
core/src/main/scala/kafka/tools/DumpLogSegments.scala changed 0.2% diff
core/src/main/scala/kafka/tools/EndToEndLatency.scala changed 2.2% diff
core/src/main/scala/kafka/tools/GetOffsetShell.scala changed 2.4% diff
core/src/main/scala/kafka/tools/JmxTool.scala changed 1.9% diff
core/src/main/scala/kafka/tools/MirrorMaker.scala changed 1.4% diff
core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala changed 4.0% diff
core/src/main/scala/org/apache/zookeeper/ZooKeeperMainWithTlsSupportForKafka.scala changed 2.6% diff
core/src/test/scala/kafka/tools/LogCompactionTester.scala changed 0.6% diff
core/src/test/scala/kafka/utils/ToolsUtilsTest.scala added
core/src/test/scala/kafka/zk/LiteralAclStoreTest.scala changed 4.2% diff
core/src/test/scala/other/kafka/ReplicationQuotasTestRig.scala changed 12.3% diff
core/src/test/scala/other/kafka/TestLinearWriteSpeed.scala changed 0.9% diff
core/src/test/scala/other/kafka/TestPurgatoryPerformance.scala changed 0.4% diff
core/src/test/scala/unit/kafka/admin/LeaderElectionCommandTest.scala changed 0.4% diff
core/src/test/scala/unit/kafka/admin/ReassignPartitionsCommandArgsTest.scala changed 64.2% diff
core/src/test/scala/unit/kafka/admin/ReassignPartitionsUnitTest.scala added
core/src/test/scala/unit/kafka/admin/ResetConsumerGroupOffsetTest.scala changed 9.5% diff
core/src/test/scala/unit/kafka/cluster/ReplicaTest.scala changed 3.9% diff
core/src/test/scala/unit/kafka/controller/ControllerChannelManagerTest.scala changed 38.7% diff
core/src/test/scala/unit/kafka/controller/ControllerContextTest.scala changed 1.3% diff
core/src/test/scala/unit/kafka/controller/ControllerEventManagerTest.scala changed 10.8% diff
core/src/test/scala/unit/kafka/controller/PartitionStateMachineTest.scala changed 4.1% diff
core/src/test/scala/unit/kafka/controller/ReplicaStateMachineTest.scala changed 1.0% diff
core/src/test/scala/unit/kafka/controller/TopicDeletionManagerTest.scala changed 1.7% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorTest.scala changed 6.0% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala changed 2.8% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataTest.scala changed 0.2% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorTest.scala changed 23.6% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionLogTest.scala changed 0.8% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerChannelManagerTest.scala changed 27.2% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandlerTes
t.scala
changed 2.3% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMetadataTest.scala changed 8.7% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionStateManagerTest.scala changed 2.9% diff
core/src/test/scala/unit/kafka/KafkaConfigTest.scala changed 0.3% diff
core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala added
core/src/test/scala/unit/kafka/network/RequestChannelTest.scala added
core/src/test/scala/unit/kafka/network/SocketServerTest.scala changed 6.3% diff
core/src/test/scala/unit/kafka/server/AbstractFetcherManagerTest.scala changed 4.1% diff
core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala changed 0.9% diff
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala changed 1.3% diff
core/src/test/scala/unit/kafka/server/DelayedOperationTest.scala changed 0.3% diff
core/src/test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala changed 0.2% diff
core/src/test/scala/unit/kafka/server/epoch/LeaderEpochFileCacheTest.scala changed 1.3% diff
core/src/test/scala/unit/kafka/server/epoch/OffsetsForLeaderEpochTest.scala changed 2.6% diff
core/src/test/scala/unit/kafka/server/HighwatermarkPersistenceTest.scala changed 3.4% diff
core/src/test/scala/unit/kafka/server/IsrExpirationTest.scala changed 6.8% diff
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala changed 45.5% diff
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala changed 10.4% diff
core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala changed 14.8% diff
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala changed 2.6% diff
core/src/test/scala/unit/kafka/server/ReplicaFetcherThreadTest.scala changed 0.4% diff
core/src/test/scala/unit/kafka/server/ReplicaManagerQuotasTest.scala changed 2.9% diff
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala changed 25.4% diff
core/src/test/scala/unit/kafka/server/ReplicationQuotaManagerTest.scala changed 1.0% diff
core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala removed
core/src/test/scala/unit/kafka/tools/ConsoleConsumerTest.scala changed 0.3% diff
core/src/test/scala/unit/kafka/tools/ConsoleProducerTest.scala changed 13.5% diff
core/src/test/scala/unit/kafka/tools/ConsumerPerformanceTest.scala changed 1.4% diff
core/src/test/scala/unit/kafka/tools/MirrorMakerTest.scala changed 3.2% diff
core/src/test/scala/unit/kafka/utils/JsonTest.scala changed 23.7% diff
core/src/test/scala/unit/kafka/utils/PasswordEncoderTest.scala changed 1.6% diff
core/src/test/scala/unit/kafka/utils/PoolTest.scala added
core/src/test/scala/unit/kafka/utils/SchedulerTest.scala changed 32.0% diff
core/src/test/scala/unit/kafka/utils/ShutdownableThreadTest.scala changed 2.0% diff
core/src/test/scala/unit/kafka/zk/ReassignPartitionsZNodeTest.scala changed 17.2% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/TopologyTest.scala changed 0.3% diff

Java Programs (833 of 2580):

NameStatusDeltaVisual Diff
clients/src/main/java/org/apache/kafka/clients/admin/Admin.java changed 7.6% diff
clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java changed 1.2% diff
clients/src/main/java/org/apache/kafka/clients/admin/AlterClientQuotasOptions.java added
clients/src/main/java/org/apache/kafka/clients/admin/AlterClientQuotasResult.java added
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigOp.java changed 32.7% diff
clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsOptions.java changed 11.8% diff
clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java changed 9.0% diff
clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java changed 90.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClientQuotasOptions.java added
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClientQuotasResult.java added
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsOptions.java changed 24.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/ElectLeadersOptions.java changed 5.8% diff
clients/src/main/java/org/apache/kafka/clients/admin/ElectLeadersResult.java changed 2.2% diff
clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersOptions.java changed 5.7% diff
clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersResult.java changed 1.0% diff
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java changed 8.2% diff
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsOptions.java changed 70.2% diff
clients/src/main/java/org/apache/kafka/clients/admin/ListOffsetsOptions.java changed 1.6% diff
clients/src/main/java/org/apache/kafka/clients/admin/ListOffsetsResult.java changed 4.8% diff
clients/src/main/java/org/apache/kafka/clients/admin/OffsetSpec.java changed 14.0% diff
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupOptions.java changed 21.0% diff
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResult.java changed 29.2% diff
clients/src/main/java/org/apache/kafka/clients/ClientDnsLookup.java changed 3.1% diff
clients/src/main/java/org/apache/kafka/clients/ClientUtils.java changed 11.1% diff
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java changed 14.1% diff
clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java changed 1.3% diff
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java changed 12.4% diff
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerGroupMetadata.java changed 22.8% diff
clients/src/main/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignor.java changed 35.8% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java changed 7.9% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java changed 24.9% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java changed 8.5% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java changed 0.3% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java changed 7.8% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsForLeaderEpochClient.java changed 6.7% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFuture.java changed 1.8% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java changed 19.1% diff
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java changed 3.1% diff
clients/src/main/java/org/apache/kafka/clients/consumer/LogTruncationException.java changed 41.9% diff
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java changed 6.2% diff
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.java changed 21.8% diff
clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java changed 0.4% diff
clients/src/main/java/org/apache/kafka/clients/Metadata.java changed 7.8% diff
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java changed 4.1% diff
clients/src/main/java/org/apache/kafka/clients/producer/BufferExhaustedException.java changed 32.0% diff
clients/src/main/java/org/apache/kafka/clients/producer/Callback.java changed 1.9% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java changed 6.7% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/DefaultPartitioner.java changed 27.7% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java changed 0.6% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java changed 4.3% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java changed 2.2% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java changed 3.5% diff
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java changed 3.1% diff
clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java changed 14.6% diff
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java changed 4.0% diff
clients/src/main/java/org/apache/kafka/common/ClusterResourceListener.java changed 24.4% diff
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java changed 1.1% diff
clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java changed 5.3% diff
clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java changed 22.7% diff
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java changed 0.7% diff
clients/src/main/java/org/apache/kafka/common/ElectionType.java changed 11.3% diff
clients/src/main/java/org/apache/kafka/common/errors/NotLeaderForPartitionException.java changed 10.0% diff
clients/src/main/java/org/apache/kafka/common/errors/NotLeaderOrFollowerException.java added
clients/src/main/java/org/apache/kafka/common/errors/ReplicaNotAvailableException.java changed 35.0% diff
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java changed 1.6% diff
clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java changed 48.1% diff
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetricsContext.java added
clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java changed 5.3% diff
clients/src/main/java/org/apache/kafka/common/metrics/MetricsContext.java added
clients/src/main/java/org/apache/kafka/common/metrics/MetricsReporter.java changed 53.4% diff
clients/src/main/java/org/apache/kafka/common/metrics/QuotaViolationException.java changed 36.5% diff
clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java changed 9.9% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/Histogram.java changed 1.8% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/Percentiles.java changed 21.1% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/SampledStat.java changed 1.1% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/SimpleRate.java changed 5.5% diff
clients/src/main/java/org/apache/kafka/common/network/ByteBufferSend.java changed 12.0% diff
clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java changed 0.4% diff
clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java changed 0.7% diff
clients/src/main/java/org/apache/kafka/common/network/Selector.java changed 4.1% diff
clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java changed 0.9% diff
clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java changed 0.5% diff
clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java changed 16.0% diff
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java changed 6.5% diff
clients/src/main/java/org/apache/kafka/common/protocol/Message.java changed 61.7% diff
clients/src/main/java/org/apache/kafka/common/protocol/MessageUtil.java changed 100.0% diff
clients/src/main/java/org/apache/kafka/common/protocol/types/Schema.java changed 6.2% diff
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaAlteration.java added
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaEntity.java added
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaFilter.java added
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaFilterComponent.java added
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java changed 0.6% diff
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java changed 2.5% diff
clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java changed 3.4% diff
clients/src/main/java/org/apache/kafka/common/record/MultiRecordsSend.java changed 4.6% diff
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java changed 2.3% diff
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java changed 11.0% diff
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnRequest.java changed 65.3% diff
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java changed 59.0% diff
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java changed 69.1% diff
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponse.java changed 73.1% diff
clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java added
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsRequest.java changed 67.1% diff
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsResponse.java changed 70.4% diff
clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsResponse.java changed 22.1% diff
clients/src/main/java/org/apache/kafka/common/requests/ApiError.java changed 9.1% diff
clients/src/main/java/org/apache/kafka/common/requests/ControlledShutdownResponse.java changed 2.7% diff
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsResponse.java changed 6.8% diff
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java changed 2.4% diff
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsResponse.java changed 12.1% diff
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java changed 10.0% diff
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsResponse.java changed 2.0% diff
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsResponse.java changed 5.9% diff
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsRequest.java changed 76.1% diff
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsResponse.java changed 77.8% diff
clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsResponse.java changed 10.8% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasResponse.java added
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsRequest.java changed 21.5% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java changed 24.8% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java changed 4.7% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsRequest.java changed 70.6% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java changed 70.0% diff
clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersResponse.java changed 11.1% diff
clients/src/main/java/org/apache/kafka/common/requests/EpochEndOffset.java changed 8.0% diff
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenResponse.java changed 3.5% diff
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java changed 1.5% diff
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java changed 2.8% diff
clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorResponse.java changed 2.6% diff
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java changed 3.6% diff
clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsResponse.java changed 5.4% diff
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java changed 4.2% diff
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrResponse.java changed 6.1% diff
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupResponse.java changed 2.7% diff
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsRequest.java changed 13.6% diff
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java changed 5.1% diff
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java changed 0.3% diff
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java changed 3.0% diff
clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsResponse.java changed 8.1% diff
clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java changed 15.9% diff
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java changed 2.1% diff
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java changed 7.4% diff
clients/src/main/java/org/apache/kafka/common/requests/OffsetDeleteResponse.java changed 16.4% diff
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java changed 13.1% diff
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochResponse.java changed 4.3% diff
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java changed 0.6% diff
clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java changed 2.6% diff
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenResponse.java changed 3.5% diff
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateRequest.java changed 4.6% diff
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateResponse.java changed 4.4% diff
clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeResponse.java changed 4.4% diff
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaRequest.java changed 74.4% diff
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaResponse.java changed 10.6% diff
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java changed 6.2% diff
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitRequest.java changed 19.8% diff
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java changed 4.2% diff
clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersRequest.java changed 61.8% diff
clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersResponse.java changed 77.7% diff
clients/src/main/java/org/apache/kafka/common/security/auth/SslEngineFactory.java added
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java changed 5.5% diff
clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java added
clients/src/main/java/org/apache/kafka/common/security/ssl/SslEngineBuilder.java removed
clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java changed 21.8% diff
clients/src/main/java/org/apache/kafka/common/utils/CircularIterator.java changed 100.0% diff
clients/src/main/java/org/apache/kafka/common/utils/FixedOrderMap.java changed 7.7% diff
clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollection.java changed 4.0% diff
clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashMultiCollection.java changed 9.4% diff
clients/src/main/java/org/apache/kafka/common/utils/OperatingSystem.java changed 7.2% diff
clients/src/main/java/org/apache/kafka/common/utils/SecurityUtils.java changed 3.7% diff
clients/src/main/java/org/apache/kafka/common/utils/Utils.java changed 15.2% diff
clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java changed 1.4% diff
clients/src/test/java/org/apache/kafka/clients/admin/AdminClientTestUtils.java added
clients/src/test/java/org/apache/kafka/clients/admin/ConfigTest.java changed 5.1% diff
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java changed 27.1% diff
clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java changed 100.0% diff
clients/src/test/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupOptionsTest.java changed 18.0% diff
clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java changed 14.3% diff
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerConfigTest.java changed 39.9% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java changed 20.5% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java changed 5.9% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java changed 16.8% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java changed 10.0% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/MockPartitionAssignor.java changed 16.0% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/MockRebalanceListener.java added
clients/src/test/java/org/apache/kafka/clients/consumer/internals/PartitionAssignorAdapterTest.java changed 0.5% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/SubscriptionStateTest.java changed 32.2% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ThrowOnAssignmentAssignor.java added
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java changed 9.2% diff
clients/src/test/java/org/apache/kafka/clients/consumer/MockConsumerTest.java changed 22.4% diff
clients/src/test/java/org/apache/kafka/clients/consumer/StickyAssignorTest.java changed 1.8% diff
clients/src/test/java/org/apache/kafka/clients/MetadataTest.java changed 11.3% diff
clients/src/test/java/org/apache/kafka/clients/MockClient.java changed 2.7% diff
clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java changed 1.4% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/BufferPoolTest.java changed 12.3% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java changed 0.9% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java changed 8.3% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java changed 15.6% diff
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java changed 8.6% diff
clients/src/test/java/org/apache/kafka/clients/producer/MockProducerTest.java changed 0.9% diff
clients/src/test/java/org/apache/kafka/common/config/AbstractConfigTest.java changed 5.3% diff
clients/src/test/java/org/apache/kafka/common/config/ConfigDefTest.java changed 7.8% diff
clients/src/test/java/org/apache/kafka/common/config/provider/MockFileConfigProvider.java changed 96.5% diff
clients/src/test/java/org/apache/kafka/common/message/MessageTest.java changed 15.4% diff
clients/src/test/java/org/apache/kafka/common/message/SimpleExampleMessageTest.java changed 18.6% diff
clients/src/test/java/org/apache/kafka/common/metrics/JmxReporterTest.java changed 60.4% diff
clients/src/test/java/org/apache/kafka/common/metrics/KafkaMetricsContextTest.java added
clients/src/test/java/org/apache/kafka/common/metrics/MetricsTest.java changed 9.9% diff
clients/src/test/java/org/apache/kafka/common/metrics/stats/FrequenciesTest.java changed 0.6% diff
clients/src/test/java/org/apache/kafka/common/network/EchoServer.java changed 3.6% diff
clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java changed 0.1% diff
clients/src/test/java/org/apache/kafka/common/network/SaslChannelBuilderTest.java changed 43.0% diff
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java changed 8.3% diff
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java changed 8.5% diff
clients/src/test/java/org/apache/kafka/common/network/SslTransportTls12Tls13Test.java added
clients/src/test/java/org/apache/kafka/common/network/SslVersionsTransportLayerTest.java added
clients/src/test/java/org/apache/kafka/common/protocol/ErrorsTest.java changed 1.7% diff
clients/src/test/java/org/apache/kafka/common/record/FileRecordsTest.java changed 3.7% diff
clients/src/test/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequestTest.java added
clients/src/test/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponseTest.java added
clients/src/test/java/org/apache/kafka/common/requests/EpochEndOffsetTest.java added
clients/src/test/java/org/apache/kafka/common/requests/LeaderAndIsrResponseTest.java changed 1.3% diff
clients/src/test/java/org/apache/kafka/common/requests/OffsetFetchRequestTest.java changed 15.2% diff
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java changed 15.6% diff
clients/src/test/java/org/apache/kafka/common/requests/StopReplicaRequestTest.java changed 100.0% diff
clients/src/test/java/org/apache/kafka/common/requests/StopReplicaResponseTest.java changed 28.6% diff
clients/src/test/java/org/apache/kafka/common/requests/TxnOffsetCommitRequestTest.java changed 39.3% diff
clients/src/test/java/org/apache/kafka/common/requests/WriteTxnMarkersRequestTest.java added
clients/src/test/java/org/apache/kafka/common/requests/WriteTxnMarkersResponseTest.java added
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java changed 2.0% diff
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticatorTest.ja
va
changed 2.8% diff
clients/src/test/java/org/apache/kafka/common/security/ssl/SslFactoryTest.java changed 38.2% diff
clients/src/test/java/org/apache/kafka/common/utils/CircularIteratorTest.java added
clients/src/test/java/org/apache/kafka/common/utils/FixedOrderMapTest.java changed 15.4% diff
clients/src/test/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollectionTest.java changed 10.5% diff
clients/src/test/java/org/apache/kafka/common/utils/UtilsTest.java changed 26.7% diff
clients/src/test/java/org/apache/kafka/test/TestSslUtils.java changed 10.5% diff
clients/src/test/java/org/apache/kafka/test/TestUtils.java changed 13.3% diff
connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java changed 3.7% diff
connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java changed 2.5% diff
connect/api/src/main/java/org/apache/kafka/connect/data/Values.java changed 0.1% diff
connect/api/src/main/java/org/apache/kafka/connect/sink/ErrantRecordReporter.java added
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java changed 8.1% diff
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnectorContext.java added
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java changed 34.0% diff
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java changed 11.1% diff
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnectorContext.java added
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java changed 9.0% diff
connect/api/src/main/java/org/apache/kafka/connect/transforms/predicates/Predicate.java added
connect/api/src/test/java/org/apache/kafka/connect/connector/ConnectorTest.java added
connect/api/src/test/java/org/apache/kafka/connect/sink/SinkConnectorTest.java added
connect/api/src/test/java/org/apache/kafka/connect/source/SourceConnectorTest.java added
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/Basic
AuthSecurityRestExtension.java
changed 7.5% diff
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasB
asicAuthFilter.java
changed 72.9% diff
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/Prope
rtyFileLoginModule.java
changed 40.6% diff
connect/basic-auth-extension/src/test/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasB
asicAuthFilterTest.java
changed 15.7% diff
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java changed 8.1% diff
connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java changed 19.8% diff
connect/json/src/main/java/org/apache/kafka/connect/json/JsonSerializer.java changed 42.4% diff
connect/json/src/test/java/org/apache/kafka/connect/json/JsonConverterTest.java changed 3.9% diff
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClientConfig.java changed 1.8% diff
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/RemoteClusterUtils.java changed 3.9% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java changed 2.4% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java changed 3.0% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatTask.java changed 4.6% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java changed 1.3% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java changed 1.6% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMetrics.java changed 0.8% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorTaskConfig.java changed 3.4% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/Scheduler.java changed 1.2% diff
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorConfigTest.java changed 29.2% diff
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java changed 1.6% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java changed 6.8% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/CloseableConnectorContext.java added
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java changed 2.2% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetrics.java changed 9.1% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java changed 68.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ClusterConfigState.java changed 4.8% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java changed 13.9% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java changed 20.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ExtendedAssignment.java changed 5.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAs
signor.java
changed 15.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java changed 3.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java changed 11.9% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/DeadLetterQueueReporter.java changed 7.9% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ErrorHandlingMetrics.java changed 5.9% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ErrorReporter.java changed 34.2% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/LogReporter.java changed 16.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ProcessingContext.java changed 23.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.ja
va
changed 11.1% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/WorkerErrantRecordReporter.ja
va
added
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/health/ConnectClusterStateImpl.java changed 2.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Herder.java changed 9.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/HerderConnectorContext.java changed 65.2% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/InternalSinkRecord.java added
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java changed 2.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java changed 0.8% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginScanResult.java changed 7.9% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java changed 1.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/PredicatedTransformation.java added
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResou
rce.java
changed 24.2% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.ja
va
changed 5.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java changed 8.7% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java changed 31.9% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java changed 100.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java changed 19.9% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskStatus.java changed 12.7% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TopicCreationConfig.java added
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TransformationChain.java changed 3.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java changed 24.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java changed 23.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfigTransformer.java changed 8.1% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java changed 92.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java changed 6.7% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTaskContext.java changed 3.2% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java changed 16.7% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java changed 3.8% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java changed 6.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java changed 18.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java changed 6.7% diff
connect/runtime/src/main/java/org/apache/kafka/connect/tools/PredicateDoc.java added
connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java changed 2.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/tools/TransformationDoc.java changed 11.1% diff
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceTask.java changed 2.8% diff
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectUtils.java changed 42.8% diff
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java changed 4.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java changed 100.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicCreation.java added
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicCreationGroup.java added
connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java added
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectIntegrationTestUtils.java added
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorHandle.java changed 5.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorTopicsIntegrationTest.j
ava
changed 2.9% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectWorkerIntegrationTest.jav
a
changed 52.7% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ErrantRecordSinkConnector.java added
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ErrorHandlingIntegrationTest.jav
a
changed 26.1% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ExampleConnectIntegrationTest.ja
va
changed 24.9% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/InternalTopicsIntegrationTest.ja
va
added
connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSinkConnector.java changed 4.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSourceConnector.java changed 3.7% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/RebalanceSourceConnectorsIntegra
tionTest.java
changed 19.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/SourceConnectorsIntegrationTest.
java
added
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TaskHandle.java changed 5.2% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TransformationIntegrationTest.ja
va
added
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractHerderTest.java changed 32.2% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ConnectMetricsTest.java changed 2.2% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ConnectorConfigTest.java changed 100.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedConfigTest.ja
va
changed 100.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.ja
va
changed 32.9% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAs
signorTest.java
changed 32.5% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorIncreme
ntalTest.java
changed 1.1% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMemberTest.ja
va
added
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java changed 23.2% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskWithTopicCreationTe
st.java
added
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/ErrorReporterTest.java changed 12.1% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperatorTes
t.java
changed 18.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/WorkerErrantRecordReporterTes
t.java
added
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/health/ConnectClusterStateImplTest.j
ava
changed 8.5% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginUtilsTest.java changed 87.1% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/MockConnectMetrics.java changed 5.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/PredicatedTransformationTest.java added
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResou
rceTest.java
changed 9.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResourceTes
t.java
changed 1.7% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/RestServerTest.java changed 17.4% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SourceConnectorConfigTest.java added
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneConfigTest.java added
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java changed 29.9% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/TransformationConfigTest.java changed 0.7% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConfigTest.java changed 60.4% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConnectorTest.java changed 65.7% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskTest.java changed 4.5% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskThreadedTest.java changed 1.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java changed 7.6% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskWithTopicCreationTes
t.java
added
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTaskTest.java changed 2.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTest.java changed 28.2% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerWithTopicCreationTest.java added
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaConfigBackingStoreTest.java changed 5.4% diff
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java changed 3.9% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java changed 16.6% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectClusterAssertio
ns.java
changed 67.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java changed 23.8% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/WorkerHandle.java changed 6.4% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/ConnectUtilsTest.java changed 100.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/TopicAdminTest.java changed 100.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/TopicCreationTest.java added
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Filter.java added
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java changed 42.4% diff
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/HasHeaderKey.java added
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/RecordIsTombstone.j
ava
added
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatches.ja
va
added
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/InsertFieldTest.java changed 4.8% diff
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/MaskFieldTest.java changed 100.0% diff
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/predicates/HasHeaderKeyTest.ja
va
added
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatchesTes
t.java
added
core/src/main/java/kafka/metrics/FilteringJmxReporter.java added
core/src/main/java/kafka/metrics/KafkaYammerMetrics.java added
core/src/main/scala/kafka/tools/StreamsResetter.java changed 9.3% diff
examples/src/main/java/kafka/examples/Producer.java changed 4.3% diff
generator/src/main/java/org/apache/kafka/message/ApiMessageTypeGenerator.java changed 5.2% diff
generator/src/main/java/org/apache/kafka/message/FieldSpec.java changed 2.8% diff
generator/src/main/java/org/apache/kafka/message/FieldType.java changed 4.2% diff
generator/src/main/java/org/apache/kafka/message/IsNullConditional.java changed 43.3% diff
generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java changed 27.0% diff
generator/src/main/java/org/apache/kafka/message/MessageGenerator.java changed 11.4% diff
generator/src/main/java/org/apache/kafka/message/MessageSpec.java changed 13.0% diff
generator/src/main/java/org/apache/kafka/message/StructRegistry.java changed 20.2% diff
generator/src/main/java/org/apache/kafka/message/Target.java added
generator/src/test/java/org/apache/kafka/message/IsNullConditionalTest.java changed 3.6% diff
generator/src/test/java/org/apache/kafka/message/StructRegistryTest.java changed 20.9% diff
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/acl/AclAuthorizerBenchmark.java added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java changed 0.6% diff
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/MetadataRequestBenchmark.java added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java changed 3.2% diff
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchIterationBenchmark.java changed 32.8% diff
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/CheckpointBench.java added
log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java changed 13.2% diff
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.j
ava
changed 0.6% diff
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo
.java
added
streams/examples/src/test/java/org/apache/kafka/streams/examples/docs/DeveloperGuideTesting.java changed 2.4% diff
streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorTest.j
ava
changed 4.0% diff
streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerTest
.java
added
streams/src/main/java/org/apache/kafka/streams/errors/TaskCorruptedException.java added
streams/src/main/java/org/apache/kafka/streams/errors/TaskMigratedException.java changed 61.5% diff
streams/src/main/java/org/apache/kafka/streams/internals/metrics/ClientMetrics.java changed 13.5% diff
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java changed 8.0% diff
streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java changed 4.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/CogroupedKStream.java changed 12.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java changed 3.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/Grouped.java changed 2.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java changed 18.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedDeserializer.java changed 13.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java changed 10.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.ja
va
changed 16.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKeySchema.j
ava
changed 13.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscrip
tionSendProcessorSupplier.java
changed 8.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResolve
rJoinProcessorSupplier.java
changed 11.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionRespons
eWrapperSerde.java
changed 11.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper
Serde.java
changed 29.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/FullChangeSerde.java changed 32.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseRepartitionNode.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GlobalStoreNode.java changed 15.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GroupedTableOperationReparti
tionNode.java
changed 41.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableForeignKeyJoinRe
solutionNode.java
renamed 77.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableJoinNode.java changed 3.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.j
ava
changed 53.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorGraphNode.java changed 2.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java changed 13.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StateStoreNode.java changed 14.7% 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 20.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java changed 4.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatTransform.java changed 6.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatTransformValues.java changed 6.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java changed 8.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java changed 2.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValues.java changed 7.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java changed 3.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java changed 38.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/RepartitionedInternal.java added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/BufferConfigInternal.java changed 13.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/EagerBufferConfigImpl.jav
a
changed 46.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorSu
pplier.java
changed 1.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/StrictBufferConfigImpl.ja
va
changed 39.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/SuppressedInternal.java changed 2.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TransformerSupplierAdapter.java changed 7.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableDeserializer.java changed 21.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableSerializer.java changed 20.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java changed 7.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java changed 6.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java changed 24.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java changed 1.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/Repartitioned.java added
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedSerializer.java changed 2.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/Suppressed.java changed 10.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java changed 5.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java changed 7.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/TransformerSupplier.java changed 9.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java changed 9.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKeySupplier.java changed 11.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/AbstractNotifyingBatchingRestoreCallback.j
ava
removed
streams/src/main/java/org/apache/kafka/streams/processor/AbstractNotifyingRestoreCallback.java removed
streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java changed 8.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/ConnectedStoreProvider.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java changed 12.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java changed 82.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStandbyTasks.java removed
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasks.java removed
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java removed
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java changed 5.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration
.java
changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorError.java changed 6.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ConstrainedPrioritySe
t.java
added
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/CopartitionedTopicsEn
forcer.java
changed 85.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/FallbackPriorTaskAssi
gnor.java
added
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskA
ssignor.java
added
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignor.ja
va
changed 29.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StreamsAssignmentProt
ocolVersions.java
changed 5.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java changed 65.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignor.java changed 50.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogReader.java changed 49.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRegister.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/Checkpointable.java removed
streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/CompositeRestoreListener.java removed
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStreamPartitioner.java changed 5.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorConte
xt.java
changed 11.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java changed 31.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateMaintainer.java changed 5.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java changed 13.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java changed 23.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java changed 14.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java changed 64.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicConfig.java changed 57.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java changed 9.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicProperties.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java changed 22.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.jav
a
changed 5.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java changed 3.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java changed 25.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java changed 53.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java changed 23.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java changed 76.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java changed 1.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNodePunctuator.java changed 9.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java changed 9.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java changed 77.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordBatchingStateRestoreCallba
ck.java
changed 9.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java changed 20.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java changed 70.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java changed 4.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java changed 5.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecoverableClientException.java removed
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java changed 18.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java changed 27.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java changed 22.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyContextImpl.java removed
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTaskCreator.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java changed 13.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManager.java changed 29.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java changed 74.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateRestorer.java removed
streams/src/main/java/org/apache/kafka/streams/processor/internals/StaticTopicNameExtractor.java changed 32.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java changed 4.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java changed 79.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListener.java changed 68.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java changed 77.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java changed 52.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedChangelogTopicConfig.j
ava
changed 9.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/WindowedChangelogTopicConfig.jav
a
changed 9.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java changed 13.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorSupplier.java changed 5.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreListener.java changed 15.5% diff
streams/src/main/java/org/apache/kafka/streams/state/HostInfo.java changed 39.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.j
ava
changed 17.9% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/BufferValue.java changed 12.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/BulkLoadingStore.java renamed 8.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/BatchWritingStore.java
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java changed 15.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java changed 8.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java changed 8.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStore.java changed 14.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java changed 19.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedKeyValueByte
sStore.java
changed 10.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedWindowBytesS
tore.java
changed 10.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java changed 12.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ContextualRecord.java changed 28.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ExceptionUtils.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java changed 1.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.ja
va
changed 24.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java changed 2.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java changed 3.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java changed 1.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java changed 75.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java changed 1.9% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java changed 9.9% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecordingTrigg
er.java
changed 9.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/OffsetCheckpoint.java changed 27.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/QueryableStoreProvider.java changed 17.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java changed 10.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java changed 3.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java changed 6.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java changed 6.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreChangeLogger.java removed
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java changed 19.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferChangelogDe
serializationHelper.java
added
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java changed 5.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerializer.java changed 76.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreBuilder.java changed 14.3% diff
streams/src/main/java/org/apache/kafka/streams/state/Stores.java changed 2.8% diff
streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java changed 1.9% diff
streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java changed 4.0% diff
streams/src/main/java/org/apache/kafka/streams/StoreQueryParameters.java changed 2.4% diff
streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java changed 8.4% diff
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java changed 15.3% diff
streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java changed 10.5% diff
streams/src/main/java/org/apache/kafka/streams/Topology.java changed 7.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java changed 1.3% diff
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java changed 20.8% diff
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java added
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java changed 23.5% diff
streams/src/test/java/org/apache/kafka/streams/integration/EOSUncleanShutdownIntegrationTest.java added
streams/src/test/java/org/apache/kafka/streams/integration/ForeignKeyJoinSuite.java changed 6.2% diff
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableEOSIntegrationTest.java changed 52.8% diff
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableIntegrationTest.java changed 29.7% diff
streams/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java changed 7.9% diff
streams/src/test/java/org/apache/kafka/streams/integration/HighAvailabilityTaskAssignorIntegrationT
est.java
added
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java changed 1.0% diff
streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationDedupIntegrationTest.j
ava
changed 7.0% diff
streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java changed 3.7% diff
streams/src/test/java/org/apache/kafka/streams/integration/KStreamRepartitionIntegrationTest.java added
streams/src/test/java/org/apache/kafka/streams/integration/KStreamTransformIntegrationTest.java changed 95.8% diff
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinDefaultSerdeTe
st.java
removed
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTes
t.java
changed 5.5% diff
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinMaterializatio
nIntegrationTest.java
changed 6.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/KTableSourceTopicRestartIntegrationTest.
java
changed 29.3% diff
streams/src/test/java/org/apache/kafka/streams/integration/LagFetchIntegrationTest.java changed 32.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/MetricsIntegrationTest.java changed 11.3% diff
streams/src/test/java/org/apache/kafka/streams/integration/OptimizedKTableIntegrationTest.java changed 39.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java changed 12.0% diff
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java changed 11.4% diff
streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java changed 14.2% diff
streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationWithSslTest.java changed 16.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/ResetPartitionTimeIntegrationTest.java changed 15.3% diff
streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java changed 48.7% diff
streams/src/test/java/org/apache/kafka/streams/integration/RocksDBMetricsIntegrationTest.java changed 37.7% diff
streams/src/test/java/org/apache/kafka/streams/integration/SmokeTestDriverIntegrationTest.java changed 0.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskCreationIntegrationTest.java changed 6.3% diff
streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskEOSIntegrationTest.java added
streams/src/test/java/org/apache/kafka/streams/integration/StateRestorationIntegrationTest.java changed 2.7% diff
streams/src/test/java/org/apache/kafka/streams/integration/StoreQueryIntegrationTest.java changed 41.2% diff
streams/src/test/java/org/apache/kafka/streams/integration/StoreUpgradeIntegrationTest.java changed 6.5% diff
streams/src/test/java/org/apache/kafka/streams/integration/StreamStreamJoinIntegrationTest.java changed 2.3% diff
streams/src/test/java/org/apache/kafka/streams/integration/StreamsUpgradeTestIntegrationTest.java changed 0.04% diff
streams/src/test/java/org/apache/kafka/streams/integration/SuppressionDurabilityIntegrationTest.jav
a
changed 7.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/SuppressionIntegrationTest.java changed 53.2% diff
streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java changed 0.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/TaskAssignorIntegrationTest.java added
streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java changed 15.8% diff
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java changed 33.9% diff
streams/src/test/java/org/apache/kafka/streams/integration/utils/KafkaEmbedded.java changed 1.9% diff
streams/src/test/java/org/apache/kafka/streams/internals/metrics/ClientMetricsTest.java changed 40.5% diff
streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java changed 18.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKeySchemaTe
st.java
changed 30.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResolve
rJoinProcessorSupplierTest.java
changed 2.7% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper
SerdeTest.java
changed 9.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/FullChangeSerdeTest.java changed 40.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/GraphGraceSearchUtilTest.jav
a
changed 5.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphTest.java changed 74.7% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilderTest.java changed 11.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImplTest.java changed 4.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java changed 3.5% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java changed 10.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinTest.java changed 86.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamRepartitionTest.java added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregateProce
ssorTest.java
changed 13.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregateTest.java changed 6.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableImplTest.java changed 1.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableForeignKeyJoinScenario
Test.java
added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoinTest.java changed 2.6% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoinTest.java changed 2.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoinTest.java changed 2.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoinTest.java changed 12.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableMapValuesTest.java changed 2.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableSourceTest.java changed 47.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableTransformValuesTest.java changed 0.5% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/metrics/TaskMetricsTest.java moved 14.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetricsTest.java
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorMe
tricsTest.java
changed 1.5% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SuppressScenarioTest.java changed 1.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TransformerSupplierAdapterTest.jav
a
changed 8.4% diff
streams/src/test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java removed
streams/src/test/java/org/apache/kafka/streams/perf/YahooBenchmark.java removed
streams/src/test/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContextTest.jav
a
changed 10.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/AbstractTaskTest.java removed
streams/src/test/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreatorTest.java added
streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java removed
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfoTest.ja
va
changed 29.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentTestUtils.j
ava
added
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration
Test.java
added
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ClientStateTest.java changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ConstrainedPrioritySe
tTest.java
added
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/FallbackPriorTaskAssi
gnorTest.java
added
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskA
ssignorTest.java
added
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/LegacySubscriptionInf
oSerde.java
changed 2.3% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignorTes
t.java
changed 83.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfoTest.
java
changed 57.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignorConvergen
ceTest.java
added
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovementTest.java added
streams/src/test/java/org/apache/kafka/streams/processor/internals/ClientUtilsTest.java added
streams/src/test/java/org/apache/kafka/streams/processor/internals/CompositeRestoreListenerTest.jav
a
removed
streams/src/test/java/org/apache/kafka/streams/processor/internals/CopartitionedTopicsEnforcerTest.
java
changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImplTest.j
ava
changed 2.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java changed 19.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateTaskTest.java changed 16.3% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStreamThreadTest.java changed 13.7% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/HighAvailabilityStreamsPartition
AssignorTest.java
added
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicConfigTest.java changed 3.2% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicManagerTest.java changed 14.2% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java changed 32.9% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetricsTest
.java
changed 8.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImplTest.j
ava
changed 4.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetricsTest.java changed 71.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/MockChangelogReader.java changed 45.4% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/PartitionGroupTest.java changed 69.7% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java changed 30.4% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextTest.java changed 12.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java changed 82.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyFactories.java changed 7.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java changed 19.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/PunctuationQueueTest.java changed 8.2% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordDeserializerTest.java changed 2.3% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordQueueTest.java changed 9.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfigTest.java added
streams/src/test/java/org/apache/kafka/streams/processor/internals/SinkNodeTest.java changed 58.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/SourceNodeTest.java changed 7.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java changed 85.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateConsumerTest.java changed 10.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java changed 41.2% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerStub.java changed 30.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerUtilTest.java added
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateRestorerTest.java removed
streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.jav
a
changed 57.7% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsProducerTest.java added
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java changed 65.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java changed 62.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskSuite.java changed 48.9% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/testutil/LogCaptureAppender.java changed 14.6% diff
streams/src/test/java/org/apache/kafka/streams/state/HostInfoTest.java added
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractKeyValueStoreTest.java changed 5.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStoreTe
st.java
changed 10.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingKeyValueStoreTest.java changed 19.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingSessionStoreTest.java changed 17.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingWindowStoreTest.java changed 15.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStoreTest.j
ava
changed 14.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedWindowBytesS
toreTest.java
changed 22.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStoreTest.ja
va
changed 22.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueLoggedStoreTest.java changed 12.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStoreTest.java changed 8.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryLRUCacheStoreTest.java changed 3.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemorySessionStoreTest.java changed 14.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBufferTes
t.java
changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryWindowStoreTest.java changed 1.1% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStoreTest.java changed 14.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredSessionStoreTest.java changed 11.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStoreTest.
java
changed 17.1% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreTest.java changed 18.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderTest.j
ava
changed 5.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecordingTrigg
erTest.java
changed 10.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/OffsetCheckpointTest.java changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/QueryableStoreProviderTest.java changed 59.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColu
mnFamilyOptionsAdapterTest.java
changed 12.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBKeyValueStoreTest.java changed 4.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStoreTest.java changed 9.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBSessionStoreTest.java changed 11.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java changed 24.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedSegmentedBytesStor
eTest.java
changed 9.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStoreTest.java changed 9.1% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreTest.java changed 0.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionBytesStoreTest.java renamed 11.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractSessionBytesStoreTest.java
streams/src/test/java/org/apache/kafka/streams/state/internals/StoreChangeLoggerTest.java removed
streams/src/test/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProviderTest.j
ava
changed 21.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferTest.java changed 44.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilderTest.ja
va
changed 11.1% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerializerTest.java added
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowBytesStoreTest.java renamed 9.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractWindowBytesStoreTest.java
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowStoreBuilderTest.java changed 14.1% diff
streams/src/test/java/org/apache/kafka/streams/state/KeyValueStoreTestDriver.java changed 7.9% diff
streams/src/test/java/org/apache/kafka/streams/state/StoresTest.java changed 0.7% diff
streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java changed 16.6% diff
streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java changed 39.8% diff
streams/src/test/java/org/apache/kafka/streams/tests/BrokerCompatibilityTest.java changed 16.5% diff
streams/src/test/java/org/apache/kafka/streams/tests/EosTestClient.java changed 40.2% diff
streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java changed 22.0% diff
streams/src/test/java/org/apache/kafka/streams/tests/RelationalSmokeTest.java changed 1.3% diff
streams/src/test/java/org/apache/kafka/streams/tests/RelationalSmokeTestTest.java changed 2.3% diff
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java changed 32.8% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsEosTest.java changed 18.8% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java changed 0.4% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java changed 16.2% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java changed 17.8% diff
streams/src/test/java/org/apache/kafka/streams/tools/StreamsResetterTest.java changed 4.8% diff
streams/src/test/java/org/apache/kafka/streams/TopologyTest.java changed 9.9% diff
streams/src/test/java/org/apache/kafka/streams/TopologyTestDriverWrapper.java changed 10.7% diff
streams/src/test/java/org/apache/kafka/streams/utils/UniqueTopicSerdeScope.java changed 3.2% diff
streams/src/test/java/org/apache/kafka/test/GlobalStateManagerStub.java changed 27.6% diff
streams/src/test/java/org/apache/kafka/test/InternalMockProcessorContext.java changed 21.7% diff
streams/src/test/java/org/apache/kafka/test/MockBatchingStateRestoreListener.java removed
streams/src/test/java/org/apache/kafka/test/MockClientSupplier.java changed 15.7% diff
streams/src/test/java/org/apache/kafka/test/MockInternalProcessorContext.java changed 33.6% diff
streams/src/test/java/org/apache/kafka/test/MockInternalTopicManager.java changed 21.8% diff
streams/src/test/java/org/apache/kafka/test/MockKeyValueStore.java changed 23.8% diff
streams/src/test/java/org/apache/kafka/test/MockKeyValueStoreBuilder.java changed 11.2% diff
streams/src/test/java/org/apache/kafka/test/MockProcessor.java changed 1.9% diff
streams/src/test/java/org/apache/kafka/test/MockRecordCollector.java changed 4.2% diff
streams/src/test/java/org/apache/kafka/test/MockSourceNode.java changed 17.8% diff
streams/src/test/java/org/apache/kafka/test/MockStateRestoreListener.java changed 26.7% diff
streams/src/test/java/org/apache/kafka/test/NoOpProcessorContext.java changed 33.4% diff
streams/src/test/java/org/apache/kafka/test/StateStoreProviderStub.java changed 56.2% diff
streams/src/test/java/org/apache/kafka/test/StreamsTestUtils.java changed 4.0% diff
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/internals/TestDriverProducer.ja
va
added
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java changed 20.3% diff
streams/test-utils/src/test/java/org/apache/kafka/streams/MockProcessorContextTest.java changed 1.1% diff
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java changed 9.5% diff
streams/upgrade-system-tests-0102/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.j
ava
changed 2.9% diff
streams/upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.j
ava
changed 2.9% diff
streams/upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
changed 2.9% diff
streams/upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
changed 2.9% diff
streams/upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
changed 3.3% diff
streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
changed 3.3% diff
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
changed 3.3% diff
streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
changed 3.3% diff
streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
added
tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java changed 0.3% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java changed 0.3% diff

Python Programs (49 of 141):

NameStatusDeltaVisual Diff
kafka-merge-pr.py changed 0.4% diff
release.py changed 6.8% diff
tests/kafkatest/__init__.py changed 32.9% diff
tests/kafkatest/benchmarks/core/benchmark_test.py changed 19.1% diff
tests/kafkatest/benchmarks/streams/__init__.py removed
tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py removed
tests/kafkatest/services/connect.py changed 6.4% diff
tests/kafkatest/services/console_consumer.py changed 11.7% diff
tests/kafkatest/services/kafka/kafka.py changed 7.8% diff
tests/kafkatest/services/kafka/util.py changed 100.0% diff
tests/kafkatest/services/kafka_log4j_appender.py changed 11.8% diff
tests/kafkatest/services/log_compaction_tester.py changed 6.3% diff
tests/kafkatest/services/monitor/jmx.py changed 7.4% diff
tests/kafkatest/services/performance/streams_performance.py removed
tests/kafkatest/services/replica_verification_tool.py changed 7.6% diff
tests/kafkatest/services/security/security_config.py changed 4.2% diff
tests/kafkatest/services/streams.py changed 15.8% diff
tests/kafkatest/services/streams_property.py changed 5.0% diff
tests/kafkatest/services/transactional_message_copier.py changed 1.7% diff
tests/kafkatest/services/verifiable_client.py changed 6.2% diff
tests/kafkatest/services/verifiable_producer.py changed 0.7% diff
tests/kafkatest/services/zookeeper.py changed 3.8% diff
tests/kafkatest/tests/client/client_compatibility_features_test.py changed 5.3% diff
tests/kafkatest/tests/client/client_compatibility_produce_consume_test.py changed 5.9% diff
tests/kafkatest/tests/client/consumer_test.py changed 1.0% diff
tests/kafkatest/tests/connect/connect_distributed_test.py changed 2.8% diff
tests/kafkatest/tests/connect/connect_rest_test.py changed 2.5% diff
tests/kafkatest/tests/core/compatibility_test_new_broker_test.py changed 5.8% diff
tests/kafkatest/tests/core/downgrade_test.py changed 34.6% diff
tests/kafkatest/tests/core/fetch_from_follower_test.py changed 7.4% diff
tests/kafkatest/tests/core/replication_test.py changed 5.0% diff
tests/kafkatest/tests/core/security_rolling_upgrade_test.py changed 3.5% diff
tests/kafkatest/tests/core/throttling_test.py changed 1.6% diff
tests/kafkatest/tests/core/transactions_test.py changed 6.3% diff
tests/kafkatest/tests/core/upgrade_test.py changed 16.0% diff
tests/kafkatest/tests/streams/base_streams_test.py changed 1.5% diff
tests/kafkatest/tests/streams/streams_broker_bounce_test.py changed 1.0% diff
tests/kafkatest/tests/streams/streams_broker_compatibility_test.py changed 84.5% diff
tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py changed 4.2% diff
tests/kafkatest/tests/streams/streams_cooperative_rebalance_upgrade_test.py changed 1.1% diff
tests/kafkatest/tests/streams/streams_eos_test.py changed 25.7% diff
tests/kafkatest/tests/streams/streams_optimized_test.py changed 6.6% diff
tests/kafkatest/tests/streams/streams_relational_smoke_test.py changed 18.9% diff
tests/kafkatest/tests/streams/streams_smoke_test.py changed 14.6% diff
tests/kafkatest/tests/streams/streams_standby_replica_test.py changed 4.3% diff
tests/kafkatest/tests/streams/streams_upgrade_test.py changed 7.6% diff
tests/kafkatest/utils/remote_account.py changed 42.5% diff
tests/kafkatest/version.py changed 7.1% diff
tests/setup.py changed 3.2% diff

Shell Programs (12 of 47):

NameStatusDeltaVisual Diff
bin/connect-distributed.sh changed 1.0% diff
bin/connect-mirror-maker.sh changed 1.0% diff
bin/connect-standalone.sh changed 1.0% diff
bin/kafka-run-class.sh changed 6.0% diff
bin/kafka-server-stop.sh changed 31.9% diff
bin/trogdor.sh changed 1.3% diff
bin/zookeeper-server-stop.sh changed 31.8% diff
bin/zookeeper-shell.sh changed 1.4% diff
examples/bin/java-simple-consumer-demo.sh removed
jenkins.sh changed 5.8% diff
tests/docker/run_tests.sh changed 7.5% diff
vagrant/base.sh changed 2.0% diff

JavaScript Files (all 1):

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

JSON Files (23 of 111):

NameStatusDeltaVisual Diff
clients/src/main/resources/common/message/AddPartitionsToTxnRequest.json changed 3.9% diff
clients/src/main/resources/common/message/AlterClientQuotasRequest.json added
clients/src/main/resources/common/message/AlterClientQuotasResponse.json added
clients/src/main/resources/common/message/CreateTopicsResponse.json changed 1.6% diff
clients/src/main/resources/common/message/DeleteRecordsRequest.json changed 5.7% diff
clients/src/main/resources/common/message/DeleteRecordsResponse.json changed 13.9% diff
clients/src/main/resources/common/message/DescribeClientQuotasRequest.json added
clients/src/main/resources/common/message/DescribeClientQuotasResponse.json added
clients/src/main/resources/common/message/DescribeConfigsRequest.json changed 23.7% diff
clients/src/main/resources/common/message/DescribeConfigsResponse.json changed 12.6% diff
clients/src/main/resources/common/message/DescribeGroupsResponse.json changed 5.0% diff
clients/src/main/resources/common/message/DescribeLogDirsRequest.json changed 14.4% diff
clients/src/main/resources/common/message/DescribeLogDirsResponse.json changed 3.7% diff
clients/src/main/resources/common/message/JoinGroupResponse.json changed 3.1% diff
clients/src/main/resources/common/message/ListGroupsRequest.json changed 26.1% diff
clients/src/main/resources/common/message/ListGroupsResponse.json changed 13.9% diff
clients/src/main/resources/common/message/StopReplicaRequest.json changed 54.5% diff
clients/src/main/resources/common/message/StopReplicaResponse.json changed 10.4% diff
clients/src/main/resources/common/message/SyncGroupRequest.json changed 3.4% diff
clients/src/main/resources/common/message/SyncGroupResponse.json changed 1.4% diff
clients/src/test/resources/common/message/SimpleExampleMessage.json changed 35.8% diff
streams/src/main/resources/common/message/SubscriptionInfo.json renamed 48.7% diff
streams/src/main/resources/common/message/SubscriptionInfoData.json

XML Documents (8 of 10):

NameStatusDeltaVisual Diff
checkstyle/import-control-core.xml changed 16.5% diff
checkstyle/import-control-jmh-benchmarks.xml changed 17.5% diff
checkstyle/import-control.xml changed 2.5% diff
checkstyle/suppressions.xml changed 26.9% diff
gradle/spotbugs-exclude.xml changed 6.8% diff
streams/quickstart/java/pom.xml changed 2.4% diff
streams/quickstart/java/src/main/resources/archetype-resources/pom.xml changed 0.8% diff
streams/quickstart/pom.xml changed 0.7% diff

DOS Batch Files (1 of 27):

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

Git Files (1 of 8):

NameStatusDeltaVisual Diff
.gitignore changed 5.7% diff

HTML Pages (21 of 61):

NameStatusDeltaVisual Diff
docs/configuration.html changed 0.4%
docs/connect.html changed 17.4%
docs/design.html changed 0.004%
docs/documentation.html changed 2.0%
docs/implementation.html changed 0.3%
docs/ops.html changed 1.1%
docs/protocol.html changed 0.01%
docs/security.html changed 8.6%
docs/streams/architecture.html changed 4.7%
docs/streams/core-concepts.html changed 6.6%
docs/streams/developer-guide/app-reset-tool.html changed 4.9%
docs/streams/developer-guide/config-streams.html changed 3.7%
docs/streams/developer-guide/datatypes.html changed 0.02%
docs/streams/developer-guide/dsl-api.html changed 0.7%
docs/streams/developer-guide/manage-topics.html changed 0.01%
docs/streams/developer-guide/processor-api.html changed 7.8%
docs/streams/developer-guide/running-app.html changed 0.01%
docs/streams/developer-guide/security.html changed 9.8%
docs/streams/developer-guide/write-streams.html changed 0.01%
docs/streams/upgrade-guide.html changed 5.4%
docs/upgrade.html changed 1.7%

Log Files (26 of 36):

NameStatusDeltaVisual Diff
core/src/main/scala/kafka/log/AbstractIndex.scala changed 5.7% diff
core/src/main/scala/kafka/log/LazyIndex.scala changed 81.3% diff
core/src/main/scala/kafka/log/Log.scala changed 4.7% diff
core/src/main/scala/kafka/log/LogCleaner.scala changed 5.9% diff
core/src/main/scala/kafka/log/LogCleanerManager.scala changed 9.5% diff
core/src/main/scala/kafka/log/LogConfig.scala changed 1.1% diff
core/src/main/scala/kafka/log/LogManager.scala changed 12.1% diff
core/src/main/scala/kafka/log/LogSegment.scala changed 4.1% diff
core/src/main/scala/kafka/log/LogValidator.scala changed 2.7% diff
core/src/main/scala/kafka/log/OffsetIndex.scala changed 1.6% diff
core/src/main/scala/kafka/log/ProducerStateManager.scala changed 0.5% diff
core/src/main/scala/kafka/log/TimeIndex.scala changed 1.3% diff
core/src/main/scala/kafka/log/TransactionIndex.scala changed 2.8% diff
core/src/test/scala/unit/kafka/log/BrokerCompressionTest.scala changed 1.2% diff
core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala changed 3.3% diff
core/src/test/scala/unit/kafka/log/LogCleanerLagIntegrationTest.scala changed 0.8% diff
core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala changed 18.1% diff
core/src/test/scala/unit/kafka/log/LogCleanerParameterizedIntegrationTest.scala changed 0.3% diff
core/src/test/scala/unit/kafka/log/LogCleanerTest.scala changed 1.0% diff
core/src/test/scala/unit/kafka/log/LogConcurrencyTest.scala added
core/src/test/scala/unit/kafka/log/LogManagerTest.scala changed 4.9% diff
core/src/test/scala/unit/kafka/log/LogSegmentTest.scala changed 4.4% diff
core/src/test/scala/unit/kafka/log/LogTest.scala changed 2.0% diff
core/src/test/scala/unit/kafka/log/LogValidatorTest.scala changed 4.5% diff
core/src/test/scala/unit/kafka/log/OffsetIndexTest.scala changed 0.7% diff
core/src/test/scala/unit/kafka/log/OffsetMapTest.scala changed 3.7% diff

Property Files (5 of 47):

NameStatusDeltaVisual Diff
config/log4j.properties changed 1.3% diff
gradle.properties changed 8.0% diff
gradle/wrapper/gradle-wrapper.properties changed 40.6% diff
tests/kafkatest/services/kafka/templates/kafka.properties changed 4.2% diff
tests/kafkatest/services/templates/zookeeper.properties changed 15.6% diff

YAML Files (1 of 2):

NameStatusDeltaVisual Diff
.asf.yaml added

Directories (24 of 819):

NameStatus
clients/src/main/java/org/apache/kafka/common/quota added
connect/api/src/main/java/org/apache/kafka/connect/transforms/predicates added
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates added
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/predicates added
core/src/main/java added
core/src/main/java/kafka added
core/src/main/java/kafka/metrics added
core/src/test/scala/kafka/metrics added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/acl added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/metrics removed
streams/src/test/java/org/apache/kafka/streams/perf removed
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/internals added
streams/upgrade-system-tests-25 added
streams/upgrade-system-tests-25/src added
streams/upgrade-system-tests-25/src/test added
streams/upgrade-system-tests-25/src/test/java added
streams/upgrade-system-tests-25/src/test/java/org added
streams/upgrade-system-tests-25/src/test/java/org/apache added
streams/upgrade-system-tests-25/src/test/java/org/apache/kafka added
streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests added
tests/kafkatest/benchmarks/streams moved
streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams

Licenses (all 1):

NameStatusDeltaVisual Diff
LICENSE changed 54.5% diff

Readme Files (3 of 7):

NameStatusDeltaVisual Diff
examples/README changed 71.4% diff
README.md changed 16.2% diff
tests/README.md changed 1.9% diff

Text Files (214 of 403):

NameStatusDeltaVisual Diff
build.gradle changed 7.7% diff
core/src/main/scala/kafka/api/ApiVersion.scala changed 3.0% diff
core/src/main/scala/kafka/api/LeaderAndIsr.scala changed 3.1% diff
core/src/main/scala/kafka/api/package.scala changed 2.5% diff
core/src/main/scala/kafka/cluster/Broker.scala changed 1.1% diff
core/src/main/scala/kafka/cluster/Cluster.scala removed
core/src/main/scala/kafka/cluster/Partition.scala changed 13.0% diff
core/src/main/scala/kafka/cluster/Replica.scala changed 22.0% diff
core/src/main/scala/kafka/common/InterBrokerSendThread.scala changed 0.6% diff
core/src/main/scala/kafka/controller/ControllerChannelManager.scala changed 23.6% diff
core/src/main/scala/kafka/controller/ControllerEventManager.scala changed 2.0% diff
core/src/main/scala/kafka/controller/KafkaController.scala changed 1.9% diff
core/src/main/scala/kafka/controller/PartitionStateMachine.scala changed 2.4% diff
core/src/main/scala/kafka/controller/ReplicaStateMachine.scala changed 10.8% diff
core/src/main/scala/kafka/controller/TopicDeletionManager.scala changed 1.0% diff
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala changed 4.0% diff
core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala changed 2.7% diff
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala changed 3.1% diff
core/src/main/scala/kafka/coordinator/transaction/DelayedTxnMarker.scala removed
core/src/main/scala/kafka/coordinator/transaction/ProducerIdManager.scala changed 0.6% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala changed 13.9% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala changed 27.7% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandler.scala changed 1.8% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala changed 3.7% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala changed 5.9% diff
core/src/main/scala/kafka/Kafka.scala changed 1.2% diff
core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala changed 6.5% diff
core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala changed 10.4% diff
core/src/main/scala/kafka/metrics/LinuxIoMetricsCollector.scala added
core/src/main/scala/kafka/network/SocketServer.scala changed 13.8% diff
core/src/main/scala/kafka/security/auth/Operation.scala changed 19.7% diff
core/src/main/scala/kafka/security/auth/Resource.scala changed 1.6% diff
core/src/main/scala/kafka/security/auth/ResourceType.scala changed 16.2% diff
core/src/main/scala/kafka/security/auth/SimpleAclAuthorizer.scala changed 5.6% diff
core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala changed 17.6% diff
core/src/main/scala/kafka/security/authorizer/AclEntry.scala changed 0.7% diff
core/src/main/scala/kafka/security/authorizer/AuthorizerUtils.scala changed 2.4% diff
core/src/main/scala/kafka/security/authorizer/AuthorizerWrapper.scala changed 0.5% diff
core/src/main/scala/kafka/server/AbstractFetcherThread.scala changed 0.4% diff
core/src/main/scala/kafka/server/AdminManager.scala changed 44.8% diff
core/src/main/scala/kafka/server/BrokerMetadataCheckpoint.scala changed 3.6% diff
core/src/main/scala/kafka/server/checkpoints/CheckpointFile.scala changed 35.8% diff
core/src/main/scala/kafka/server/ClientQuotaManager.scala changed 4.0% diff
core/src/main/scala/kafka/server/ClientRequestQuotaManager.scala changed 13.9% diff
core/src/main/scala/kafka/server/ConfigHandler.scala changed 6.0% diff
core/src/main/scala/kafka/server/DelayedDeleteRecords.scala changed 15.0% diff
core/src/main/scala/kafka/server/DelayedElectLeader.scala changed 2.5% diff
core/src/main/scala/kafka/server/DelayedFetch.scala changed 13.0% diff
core/src/main/scala/kafka/server/DelayedProduce.scala changed 2.0% diff
core/src/main/scala/kafka/server/DelegationTokenManager.scala changed 0.2% diff
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala changed 10.3% diff
core/src/main/scala/kafka/server/DynamicConfig.scala changed 10.9% diff
core/src/main/scala/kafka/server/DynamicConfigManager.scala changed 0.5% diff
core/src/main/scala/kafka/server/FetchSession.scala changed 2.1% diff
core/src/main/scala/kafka/server/KafkaApis.scala changed 19.2% diff
core/src/main/scala/kafka/server/KafkaConfig.scala changed 1.1% diff
core/src/main/scala/kafka/server/KafkaRequestHandler.scala changed 0.3% diff
core/src/main/scala/kafka/server/KafkaServer.scala changed 7.7% diff
core/src/main/scala/kafka/server/MetadataCache.scala changed 21.7% diff
core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala changed 5.1% diff
core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala changed 1.9% diff
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala changed 1.9% diff
core/src/main/scala/kafka/server/ReplicaManager.scala changed 21.9% diff
core/src/main/scala/kafka/server/ReplicationQuotaManager.scala changed 7.1% diff
core/src/main/scala/kafka/server/ThrottledChannel.scala changed 17.8% diff
core/src/main/scala/kafka/utils/CoreUtils.scala changed 4.0% diff
core/src/main/scala/kafka/utils/Implicits.scala changed 2.6% diff
core/src/main/scala/kafka/utils/Json.scala changed 39.2% diff
core/src/main/scala/kafka/utils/json/DecodeJson.scala changed 5.0% diff
core/src/main/scala/kafka/utils/json/JsonArray.scala changed 7.0% diff
core/src/main/scala/kafka/utils/json/JsonObject.scala changed 2.7% diff
core/src/main/scala/kafka/utils/Log4jController.scala changed 1.2% diff
core/src/main/scala/kafka/utils/Pool.scala changed 10.5% diff
core/src/main/scala/kafka/utils/timer/TimerTaskList.scala changed 3.2% diff
core/src/main/scala/kafka/utils/ToolsUtils.scala changed 9.5% diff
core/src/main/scala/kafka/utils/VerifiableProperties.scala changed 0.6% diff
core/src/main/scala/kafka/zk/AdminZkClient.scala changed 2.4% diff
core/src/main/scala/kafka/zk/KafkaZkClient.scala changed 2.1% diff
core/src/main/scala/kafka/zk/ZkData.scala changed 0.7% diff
core/src/main/scala/kafka/zookeeper/ZooKeeperClient.scala changed 1.8% diff
core/src/test/scala/integration/kafka/admin/ReassignPartitionsIntegrationTest.scala changed 100.0% diff
core/src/test/scala/integration/kafka/api/AbstractConsumerTest.scala changed 1.2% diff
core/src/test/scala/integration/kafka/api/AdminClientWithPoliciesIntegrationTest.scala changed 1.1% diff
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala changed 36.2% diff
core/src/test/scala/integration/kafka/api/BaseAdminIntegrationTest.scala changed 1.9% diff
core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala changed 1.6% diff
core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala changed 0.5% diff
core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala changed 26.5% diff
core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala changed 0.6% diff
core/src/test/scala/integration/kafka/api/ConsumerTopicCreationTest.scala changed 1.8% diff
core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala changed 4.8% diff
core/src/test/scala/integration/kafka/api/DelegationTokenEndToEndAuthorizationTest.scala changed 13.1% diff
core/src/test/scala/integration/kafka/api/DescribeAuthorizedOperationsTest.scala changed 1.6% diff
core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala changed 7.5% diff
core/src/test/scala/integration/kafka/api/EndToEndClusterIdTest.scala changed 0.4% diff
core/src/test/scala/integration/kafka/api/GroupAuthorizerIntegrationTest.scala changed 100.0% diff
core/src/test/scala/integration/kafka/api/GroupCoordinatorIntegrationTest.scala changed 1.5% diff
core/src/test/scala/integration/kafka/api/GroupEndToEndAuthorizationTest.scala changed 9.2% diff
core/src/test/scala/integration/kafka/api/MetricsTest.scala changed 3.1% diff
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala changed 13.9% diff
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala changed 0.3% diff
core/src/test/scala/integration/kafka/api/PlaintextEndToEndAuthorizationTest.scala changed 4.8% diff
core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala changed 7.9% diff
core/src/test/scala/integration/kafka/api/ProducerCompressionTest.scala changed 1.0% diff
core/src/test/scala/integration/kafka/api/ProducerFailureHandlingTest.scala changed 0.4% diff
core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala changed 1.8% diff
core/src/test/scala/integration/kafka/api/SaslEndToEndAuthorizationTest.scala changed 1.2% diff
core/src/test/scala/integration/kafka/api/SaslGssapiSslEndToEndAuthorizationTest.scala changed 16.3% diff
core/src/test/scala/integration/kafka/api/SaslMultiMechanismConsumerTest.scala changed 1.1% diff
core/src/test/scala/integration/kafka/api/SaslOAuthBearerSslEndToEndAuthorizationTest.scala changed 23.7% diff
core/src/test/scala/integration/kafka/api/SaslPlainSslEndToEndAuthorizationTest.scala changed 5.2% diff
core/src/test/scala/integration/kafka/api/SaslScramSslEndToEndAuthorizationTest.scala changed 18.0% diff
core/src/test/scala/integration/kafka/api/SaslSetup.scala changed 17.1% diff
core/src/test/scala/integration/kafka/api/SaslSslAdminIntegrationTest.scala changed 0.6% diff
core/src/test/scala/integration/kafka/api/SslAdminIntegrationTest.scala changed 2.3% diff
core/src/test/scala/integration/kafka/api/SslEndToEndAuthorizationTest.scala changed 5.1% diff
core/src/test/scala/integration/kafka/api/TransactionsBounceTest.scala changed 18.7% diff
core/src/test/scala/integration/kafka/api/TransactionsExpirationTest.scala changed 0.8% diff
core/src/test/scala/integration/kafka/api/TransactionsTest.scala changed 8.4% diff
core/src/test/scala/integration/kafka/network/DynamicConnectionQuotaTest.scala changed 1.3% diff
core/src/test/scala/integration/kafka/server/DelayedFetchTest.scala changed 45.2% diff
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala changed 4.2% diff
core/src/test/scala/integration/kafka/server/GssapiAuthenticationTest.scala changed 0.5% diff
core/src/test/scala/integration/kafka/server/ScramServerStartupTest.scala changed 1.5% diff
core/src/test/scala/kafka/metrics/LinuxIoMetricsCollectorTest.scala added
core/src/test/scala/kafka/security/minikdc/MiniKdc.scala changed 0.9% diff
core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala changed 5.4% diff
core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala changed 0.8% diff
core/src/test/scala/unit/kafka/admin/ConfigCommandTest.scala changed 24.2% diff
core/src/test/scala/unit/kafka/admin/ConsumerGroupCommandTest.scala changed 3.5% diff
core/src/test/scala/unit/kafka/admin/DelegationTokenCommandTest.scala changed 2.3% diff
core/src/test/scala/unit/kafka/admin/DeleteConsumerGroupsTest.scala changed 4.7% diff
core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala changed 11.8% diff
core/src/test/scala/unit/kafka/admin/ListConsumerGroupTest.scala changed 100.0% diff
core/src/test/scala/unit/kafka/admin/PreferredReplicaLeaderElectionCommandTest.scala changed 0.7% diff
core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala removed
core/src/test/scala/unit/kafka/admin/ReassignPartitionsCommandTest.scala removed
core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala changed 11.9% diff
core/src/test/scala/unit/kafka/admin/TopicCommandWithZKClientTest.scala added
core/src/test/scala/unit/kafka/cluster/AssignmentStateTest.scala changed 2.8% diff
core/src/test/scala/unit/kafka/cluster/PartitionLockTest.scala changed 20.3% diff
core/src/test/scala/unit/kafka/cluster/PartitionTest.scala changed 11.3% diff
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala changed 2.8% diff
core/src/test/scala/unit/kafka/coordinator/AbstractCoordinatorConcurrencyTest.scala changed 0.5% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorConcurrencyTest.scala changed 20.6% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorConcurrencyTest.scala changed 3.6% diff
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala changed 2.2% diff
core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala changed 10.9% diff
core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala changed 5.2% diff
core/src/test/scala/unit/kafka/metrics/MetricsTest.scala changed 19.3% diff
core/src/test/scala/unit/kafka/security/auth/SimpleAclAuthorizerTest.scala changed 0.4% diff
core/src/test/scala/unit/kafka/security/auth/ZkAuthorizationTest.scala changed 1.4% diff
core/src/test/scala/unit/kafka/security/authorizer/AclAuthorizerTest.scala changed 7.5% diff
core/src/test/scala/unit/kafka/security/token/delegation/DelegationTokenManagerTest.scala changed 0.9% diff
core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala changed 1.6% diff
core/src/test/scala/unit/kafka/server/AbstractCreateTopicsRequestTest.scala changed 1.2% diff
core/src/test/scala/unit/kafka/server/AddPartitionsToTxnRequestTest.scala renamed 20.0% diff
core/src/test/scala/unit/kafka/server/AddPartitionsToTxnRequestServerTest.scala
core/src/test/scala/unit/kafka/server/AlterReplicaLogDirsRequestTest.scala changed 0.7% diff
core/src/test/scala/unit/kafka/server/BaseRequestTest.scala changed 2.4% diff
core/src/test/scala/unit/kafka/server/BrokerEpochIntegrationTest.scala changed 13.5% diff
core/src/test/scala/unit/kafka/server/ClientQuotasRequestTest.scala added
core/src/test/scala/unit/kafka/server/CreateTopicsRequestTest.scala changed 0.5% diff
core/src/test/scala/unit/kafka/server/CreateTopicsRequestWithPolicyTest.scala changed 0.6% diff
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsOnPlainTextTest.scala changed 5.1% diff
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsTest.scala changed 2.4% diff
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsWithDisableTokenFeatureTest.scala changed 4.1% diff
core/src/test/scala/unit/kafka/server/DeleteTopicsRequestTest.scala changed 1.8% diff
core/src/test/scala/unit/kafka/server/DescribeLogDirsRequestTest.scala changed 6.1% diff
core/src/test/scala/unit/kafka/server/DynamicConfigChangeTest.scala changed 0.3% diff
core/src/test/scala/unit/kafka/server/EdgeCaseRequestTest.scala changed 0.7% diff
core/src/test/scala/unit/kafka/server/epoch/EpochDrivenReplicationProtocolAcceptanceTest.scala changed 0.2% diff
core/src/test/scala/unit/kafka/server/epoch/LeaderEpochIntegrationTest.scala changed 2.2% diff
core/src/test/scala/unit/kafka/server/FetchRequestMaxBytesTest.scala changed 0.9% diff
core/src/test/scala/unit/kafka/server/FetchRequestTest.scala changed 0.9% diff
core/src/test/scala/unit/kafka/server/KafkaMetricsReporterTest.scala added
core/src/test/scala/unit/kafka/server/LeaderElectionTest.scala changed 1.4% diff
core/src/test/scala/unit/kafka/server/ListOffsetsRequestTest.scala changed 8.5% diff
core/src/test/scala/unit/kafka/server/LogDirFailureTest.scala changed 5.6% diff
core/src/test/scala/unit/kafka/server/LogOffsetTest.scala changed 3.3% diff
core/src/test/scala/unit/kafka/server/MetadataRequestTest.scala changed 1.0% diff
core/src/test/scala/unit/kafka/server/OffsetsForLeaderEpochRequestTest.scala changed 8.1% diff
core/src/test/scala/unit/kafka/server/ProduceRequestTest.scala changed 2.7% diff
core/src/test/scala/unit/kafka/server/ReplicationQuotasTest.scala changed 1.3% diff
core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala changed 8.8% diff
core/src/test/scala/unit/kafka/server/ServerGenerateClusterIdTest.scala changed 2.0% diff
core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala changed 1.0% diff
core/src/test/scala/unit/kafka/server/ServerStartupTest.scala changed 1.8% diff
core/src/test/scala/unit/kafka/server/StopReplicaRequestTest.scala changed 41.3% diff
core/src/test/scala/unit/kafka/utils/CoreUtilsTest.scala changed 0.9% diff
core/src/test/scala/unit/kafka/utils/MockScheduler.scala changed 21.4% diff
core/src/test/scala/unit/kafka/utils/TestUtils.scala changed 4.0% diff
core/src/test/scala/unit/kafka/utils/timer/MockTimer.scala changed 3.4% diff
core/src/test/scala/unit/kafka/zk/AdminZkClientTest.scala changed 1.7% diff
core/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala changed 4.3% diff
core/src/test/scala/unit/kafka/zk/ZooKeeperTestHarness.scala changed 0.8% diff
core/src/test/scala/unit/kafka/zookeeper/ZooKeeperClientTest.scala changed 8.4% diff
gradle/dependencies.gradle changed 9.5% diff
gradlew changed 16.4% diff
gradlewAll added
settings.gradle changed 2.4% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionConversions.scala changed 1.1% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionsCompatConversions.scal
a
changed 0.7% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/ImplicitConversions.scala changed 3.4% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala changed 6.8% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/package.scala changed 5.9% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Repartitioned.scala added
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala changed 3.5% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala changed 8.1% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/ProducedTest.scala changed 17.7% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/RepartitionedTest.scala added
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/utils/StreamToTableJoinScalaInt
egrationTestBase.scala
changed 0.9% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/WordCountTest.scala changed 2.0% diff
tests/docker/Dockerfile changed 10.3% diff

Packages Compared:

kafka-2.5.0-src.tgz
kafka-2.6.0-src.tgz


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