"Fossies" - the Fresh Open Source Software Archive  

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

About: Apache kafka is a distributed streaming platform.

Summary:

The "kafka" source code changed by about 9.3% and now consists of 3520 regular files (+88) and 798 directories (+23).

Related Informations:

None found by Fossies.

Changes In Files (According File Type):

File TypeTotalAddedRemovedChanged
C program 115 5 0 68
Java program 2469 77 11 518
Python program 142 5 1 34
Shell program 47 1 0 4
Ruby program 1 0 0 0
Configuration file 7 0 0 0
JavaScript file 1 0 0 1
JSON file 106 1 0 33
XML document 10 0 0 7
DOS Batch file 27 0 0 1
Git file 8 0 0 1
HTML page 61 0 0 17
Log file 35 0 0 15
Property file 47 1 0 6
RDF file 1 0 0 0
XML style sheet 1 0 0 0
YAML file 1 0 0 0
Image file 49 0 0 0
Directory 799 24 1 0
Information file 3 0 0 0
License 1 0 0 0
Readme file 7 0 0 3
Text file 395 14 4 163
Other 2 0 0 0
Total Files433512817871



C Programs (73 of 115):

NameStatusDeltaVisual Diff
core/src/main/scala/kafka/admin/AclCommand.scala changed 18.7% diff
core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala changed 6.5% diff
core/src/main/scala/kafka/admin/ConfigCommand.scala changed 49.3% diff
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala changed 4.8% diff
core/src/main/scala/kafka/admin/DelegationTokenCommand.scala changed 2.0% diff
core/src/main/scala/kafka/admin/DeleteRecordsCommand.scala changed 4.0% diff
core/src/main/scala/kafka/admin/LeaderElectionCommand.scala changed 2.6% diff
core/src/main/scala/kafka/admin/LogDirsCommand.scala changed 2.6% diff
core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala changed 2.0% diff
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala changed 0.7% diff
core/src/main/scala/kafka/admin/TopicCommand.scala changed 8.7% diff
core/src/main/scala/kafka/admin/ZkSecurityMigrator.scala changed 44.9% diff
core/src/main/scala/kafka/controller/ControllerContext.scala changed 11.3% diff
core/src/main/scala/kafka/network/RequestChannel.scala changed 2.8% diff
core/src/main/scala/kafka/tools/ConsoleConsumer.scala changed 2.6% diff
core/src/main/scala/kafka/tools/ConsoleProducer.scala changed 10.0% diff
core/src/main/scala/kafka/tools/ConsumerPerformance.scala changed 6.5% diff
core/src/main/scala/kafka/tools/EndToEndLatency.scala changed 2.9% diff
core/src/main/scala/kafka/tools/MirrorMaker.scala changed 1.3% diff
core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala changed 1.3% diff
core/src/main/scala/org/apache/zookeeper/ZooKeeperMainWithTlsSupportForKafka.scala added
core/src/test/scala/kafka/security/auth/ResourceTest.scala changed 3.2% diff
core/src/test/scala/kafka/security/minikdc/MiniKdcTest.scala added
core/src/test/scala/kafka/server/BrokerMetadataCheckpointTest.scala added
core/src/test/scala/kafka/tools/CustomDeserializerTest.scala changed 97.8% diff
core/src/test/scala/kafka/tools/LogCompactionTester.scala changed 1.2% diff
core/src/test/scala/kafka/tools/ReplicaVerificationToolTest.scala changed 33.2% diff
core/src/test/scala/kafka/utils/ExitTest.scala added
core/src/test/scala/kafka/zk/ExtendedAclStoreTest.scala changed 15.2% diff
core/src/test/scala/kafka/zk/LiteralAclStoreTest.scala changed 24.5% diff
core/src/test/scala/other/kafka/StressTestLog.scala changed 1.9% diff
core/src/test/scala/unit/kafka/admin/AclCommandTest.scala changed 9.5% diff
core/src/test/scala/unit/kafka/admin/LeaderElectionCommandTest.scala changed 6.5% diff
core/src/test/scala/unit/kafka/cluster/AbstractPartitionTest.scala added
core/src/test/scala/unit/kafka/controller/ControllerChannelManagerTest.scala changed 4.0% diff
core/src/test/scala/unit/kafka/controller/ControllerContextTest.scala changed 23.9% diff
core/src/test/scala/unit/kafka/controller/ControllerEventManagerTest.scala changed 22.7% diff
core/src/test/scala/unit/kafka/controller/PartitionStateMachineTest.scala changed 4.6% diff
core/src/test/scala/unit/kafka/controller/ReplicaStateMachineTest.scala changed 5.0% diff
core/src/test/scala/unit/kafka/controller/TopicDeletionManagerTest.scala changed 13.4% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorTest.scala changed 18.8% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala changed 3.1% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataTest.scala changed 5.6% diff
core/src/test/scala/unit/kafka/coordinator/transaction/ProducerIdManagerTest.scala changed 30.3% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorTest.scala changed 63.9% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionLogTest.scala changed 2.3% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerChannelManagerTest.scala changed 5.6% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandlerTes
t.scala
changed 5.9% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMetadataTest.scala changed 100.0% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionStateManagerTest.scala changed 4.3% diff
core/src/test/scala/unit/kafka/KafkaConfigTest.scala changed 100.0% diff
core/src/test/scala/unit/kafka/network/SocketServerTest.scala changed 41.5% diff
core/src/test/scala/unit/kafka/security/auth/OperationTest.scala changed 5.8% diff
core/src/test/scala/unit/kafka/security/auth/PermissionTypeTest.scala changed 4.3% diff
core/src/test/scala/unit/kafka/security/auth/ResourceTypeTest.scala changed 4.2% diff
core/src/test/scala/unit/kafka/server/AbstractFetcherManagerTest.scala changed 2.9% diff
core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala changed 3.2% diff
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala changed 29.9% diff
core/src/test/scala/unit/kafka/server/FetchSessionTest.scala changed 89.4% diff
core/src/test/scala/unit/kafka/server/HighwatermarkPersistenceTest.scala changed 1.6% diff
core/src/test/scala/unit/kafka/server/IsrExpirationTest.scala changed 1.1% diff
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala changed 48.2% diff
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala changed 2.6% diff
core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala changed 6.9% diff
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala changed 39.2% diff
core/src/test/scala/unit/kafka/server/ReplicaFetcherThreadTest.scala changed 11.6% diff
core/src/test/scala/unit/kafka/server/ReplicaManagerQuotasTest.scala changed 1.6% diff
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala changed 6.1% diff
core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala changed 1.2% diff
core/src/test/scala/unit/kafka/server/ThrottledChannelExpirationTest.scala changed 2.4% diff
core/src/test/scala/unit/kafka/tools/ConsoleProducerTest.scala changed 57.5% diff
core/src/test/scala/unit/kafka/tools/ConsumerPerformanceTest.scala changed 35.6% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/TopologyTest.scala changed 37.9% diff

Java Programs (606 of 2469):

NameStatusDeltaVisual Diff
clients/src/main/java/org/apache/kafka/clients/admin/AbstractOptions.java changed 14.8% diff
clients/src/main/java/org/apache/kafka/clients/admin/Admin.java changed 22.1% diff
clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java changed 6.2% diff
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsOptions.java changed 6.2% diff
clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsOptions.java added
clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsResult.java added
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsResult.java changed 100.0% diff
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsOptions.java changed 7.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsOptions.java changed 6.1% diff
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsResult.java changed 2.7% diff
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsOptions.java changed 7.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsOptions.java changed 7.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsOptions.java changed 7.8% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterOptions.java changed 5.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsOptions.java changed 6.1% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsOptions.java changed 6.4% diff
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsResult.java changed 33.3% diff
clients/src/main/java/org/apache/kafka/clients/admin/internals/ConsumerGroupOperationContext.java added
clients/src/main/java/org/apache/kafka/clients/admin/internals/MetadataOperationContext.java added
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java changed 19.5% diff
clients/src/main/java/org/apache/kafka/clients/admin/ListOffsetsOptions.java added
clients/src/main/java/org/apache/kafka/clients/admin/ListOffsetsResult.java added
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsOptions.java changed 5.9% diff
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsResult.java changed 24.8% diff
clients/src/main/java/org/apache/kafka/clients/admin/NewTopic.java changed 11.6% diff
clients/src/main/java/org/apache/kafka/clients/admin/OffsetSpec.java added
clients/src/main/java/org/apache/kafka/clients/ClientUtils.java changed 6.6% diff
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java changed 2.5% diff
clients/src/main/java/org/apache/kafka/clients/consumer/CommitFailedException.java changed 4.4% diff
clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java changed 1.4% diff
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java changed 1.5% diff
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerGroupMetadata.java changed 86.4% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java changed 10.2% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java changed 10.1% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java changed 2.2% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Heartbeat.java changed 17.6% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/KafkaConsumerMetrics.java changed 1.0% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsForLeaderEpochClient.java changed 30.9% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java changed 1.4% diff
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java changed 7.4% diff
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java changed 2.5% diff
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndMetadata.java changed 3.0% diff
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetCommitCallback.java changed 11.6% diff
clients/src/main/java/org/apache/kafka/clients/consumer/RetriableCommitFailedException.java changed 20.2% diff
clients/src/main/java/org/apache/kafka/clients/consumer/RoundRobinAssignor.java changed 1.9% diff
clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java changed 18.2% diff
clients/src/main/java/org/apache/kafka/clients/Metadata.java changed 36.4% diff
clients/src/main/java/org/apache/kafka/clients/MetadataCache.java changed 80.0% diff
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java changed 2.9% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java changed 1.8% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerIdAndEpoch.java moved 57.3% diff
clients/src/main/java/org/apache/kafka/common/utils/ProducerIdAndEpoch.java
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetadata.java changed 35.7% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java changed 5.2% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java changed 13.3% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionalRequestResult.java changed 2.8% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java changed 34.1% diff
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java changed 11.0% diff
clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java changed 2.6% diff
clients/src/main/java/org/apache/kafka/clients/producer/Producer.java changed 11.3% diff
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java changed 16.2% diff
clients/src/main/java/org/apache/kafka/common/Cluster.java changed 4.7% diff
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java changed 0.2% diff
clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java changed 0.9% diff
clients/src/main/java/org/apache/kafka/common/config/provider/ConfigProvider.java changed 3.6% diff
clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java changed 2.9% diff
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java changed 4.6% diff
clients/src/main/java/org/apache/kafka/common/errors/UnstableOffsetCommitException.java added
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java changed 6.2% diff
clients/src/main/java/org/apache/kafka/common/MetricName.java changed 3.1% diff
clients/src/main/java/org/apache/kafka/common/metrics/internals/IntGaugeSuite.java added
clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java changed 14.3% diff
clients/src/main/java/org/apache/kafka/common/metrics/MetricConfig.java changed 0.7% diff
clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java changed 4.3% diff
clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java changed 1.9% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/Percentiles.java changed 2.0% diff
clients/src/main/java/org/apache/kafka/common/network/Authenticator.java changed 10.8% diff
clients/src/main/java/org/apache/kafka/common/network/ByteBufferSend.java changed 3.0% diff
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilder.java changed 11.6% diff
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilders.java changed 24.0% diff
clients/src/main/java/org/apache/kafka/common/network/ChannelMetadataRegistry.java added
clients/src/main/java/org/apache/kafka/common/network/CipherInformation.java added
clients/src/main/java/org/apache/kafka/common/network/ClientInformation.java added
clients/src/main/java/org/apache/kafka/common/network/DefaultChannelMetadataRegistry.java added
clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java changed 10.7% diff
clients/src/main/java/org/apache/kafka/common/network/NetworkReceive.java changed 5.1% diff
clients/src/main/java/org/apache/kafka/common/network/PlaintextChannelBuilder.java changed 13.3% diff
clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java changed 31.4% diff
clients/src/main/java/org/apache/kafka/common/network/Selectable.java changed 4.9% diff
clients/src/main/java/org/apache/kafka/common/network/Selector.java changed 22.1% diff
clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java changed 15.0% diff
clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java changed 20.8% diff
clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java changed 5.9% diff
clients/src/main/java/org/apache/kafka/common/protocol/ByteBufferAccessor.java changed 23.3% diff
clients/src/main/java/org/apache/kafka/common/protocol/CommonFields.java changed 43.4% diff
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java changed 1.2% diff
clients/src/main/java/org/apache/kafka/common/protocol/Readable.java changed 5.2% diff
clients/src/main/java/org/apache/kafka/common/protocol/types/Field.java changed 5.4% diff
clients/src/main/java/org/apache/kafka/common/protocol/types/SchemaException.java changed 8.5% diff
clients/src/main/java/org/apache/kafka/common/protocol/types/Struct.java changed 3.3% diff
clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java changed 3.4% diff
clients/src/main/java/org/apache/kafka/common/protocol/Writable.java changed 8.5% diff
clients/src/main/java/org/apache/kafka/common/record/CompressionRatioEstimator.java changed 2.7% diff
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java changed 3.7% diff
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsRequest.java changed 8.7% diff
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsRequest.java changed 6.7% diff
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsRequest.java changed 73.0% diff
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsResponse.java changed 69.5% diff
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsRequest.java changed 84.5% diff
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsResponse.java changed 71.3% diff
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsRequest.java changed 70.6% diff
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsResponse.java changed 81.1% diff
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsRequest.java changed 5.8% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsRequest.java changed 62.6% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsResponse.java changed 79.9% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsRequest.java changed 11.3% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java changed 3.4% diff
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsRequest.java changed 7.7% diff
clients/src/main/java/org/apache/kafka/common/requests/EndTxnRequest.java changed 67.3% diff
clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java changed 53.4% diff
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java changed 0.2% diff
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java changed 0.6% diff
clients/src/main/java/org/apache/kafka/common/requests/IsolationLevel.java moved 3.2% diff
clients/src/main/java/org/apache/kafka/common/IsolationLevel.java
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java changed 26.1% diff
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java changed 6.1% diff
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java changed 3.6% diff
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java changed 0.6% diff
clients/src/main/java/org/apache/kafka/common/requests/MetadataRequest.java changed 9.8% diff
clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java changed 22.5% diff
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java changed 14.9% diff
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java changed 16.7% diff
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java changed 0.5% diff
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java changed 3.0% diff
clients/src/main/java/org/apache/kafka/common/requests/RequestContext.java changed 6.0% diff
clients/src/main/java/org/apache/kafka/common/requests/RequestUtils.java changed 72.0% diff
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateRequest.java changed 3.8% diff
clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeRequest.java changed 4.0% diff
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupRequest.java changed 23.7% diff
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java changed 4.2% diff
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitRequest.java changed 21.6% diff
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java changed 2.7% diff
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java changed 8.9% diff
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java changed 5.2% diff
clients/src/main/java/org/apache/kafka/common/security/JaasUtils.java changed 10.5% diff
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosError.java changed 14.1% diff
clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java changed 0.8% diff
clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java changed 4.2% diff
clients/src/main/java/org/apache/kafka/common/serialization/VoidDeserializer.java added
clients/src/main/java/org/apache/kafka/common/serialization/VoidSerializer.java added
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferUnmapper.java added
clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java changed 8.9% diff
clients/src/main/java/org/apache/kafka/common/utils/Exit.java changed 40.3% diff
clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollection.java changed 0.6% diff
clients/src/main/java/org/apache/kafka/common/utils/Java.java changed 7.3% diff
clients/src/main/java/org/apache/kafka/common/utils/KafkaThread.java changed 12.2% diff
clients/src/main/java/org/apache/kafka/common/utils/MappedByteBuffers.java removed
clients/src/main/java/org/apache/kafka/common/utils/SecurityUtils.java changed 40.7% diff
clients/src/main/java/org/apache/kafka/common/utils/Utils.java changed 7.7% diff
clients/src/test/java/org/apache/kafka/clients/admin/ConfigTest.java changed 11.3% diff
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java changed 37.5% diff
clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java changed 4.1% diff
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerGroupMetadataTest.java added
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java changed 21.1% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java changed 6.4% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerMetadataTest.java changed 9.9% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClientTest.java changed 1.1% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java changed 4.3% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/OffsetForLeaderEpochClientTest.ja
va
changed 4.2% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/PartitionAssignorAdapterTest.java changed 2.0% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/SubscriptionStateTest.java changed 9.1% diff
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java changed 7.8% diff
clients/src/test/java/org/apache/kafka/clients/consumer/MockConsumerTest.java changed 18.8% diff
clients/src/test/java/org/apache/kafka/clients/FetchSessionHandlerTest.java changed 10.2% diff
clients/src/test/java/org/apache/kafka/clients/MetadataCacheTest.java added
clients/src/test/java/org/apache/kafka/clients/MetadataTest.java changed 45.9% diff
clients/src/test/java/org/apache/kafka/clients/MockClient.java changed 0.5% diff
clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java changed 0.2% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/ProducerMetadataTest.java changed 70.2% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java changed 7.7% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java changed 17.0% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java changed 52.8% diff
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java changed 33.8% diff
clients/src/test/java/org/apache/kafka/clients/producer/MockProducerTest.java changed 22.0% diff
clients/src/test/java/org/apache/kafka/common/internals/PartitionStatesTest.java changed 6.3% diff
clients/src/test/java/org/apache/kafka/common/message/MessageTest.java changed 4.9% diff
clients/src/test/java/org/apache/kafka/common/message/SimpleExampleMessageTest.java changed 100.0% diff
clients/src/test/java/org/apache/kafka/common/metrics/internals/IntGaugeSuiteTest.java added
clients/src/test/java/org/apache/kafka/common/metrics/SensorTest.java changed 9.3% diff
clients/src/test/java/org/apache/kafka/common/network/ChannelBuildersTest.java changed 51.6% diff
clients/src/test/java/org/apache/kafka/common/network/KafkaChannelTest.java added
clients/src/test/java/org/apache/kafka/common/network/NetworkReceiveTest.java added
clients/src/test/java/org/apache/kafka/common/network/NetworkTestUtils.java changed 2.3% diff
clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java changed 3.4% diff
clients/src/test/java/org/apache/kafka/common/network/SaslChannelBuilderTest.java changed 100.0% diff
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java changed 40.4% diff
clients/src/test/java/org/apache/kafka/common/network/SslSelectorTest.java changed 16.1% diff
clients/src/test/java/org/apache/kafka/common/network/SslSender.java changed 7.6% diff
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java changed 10.9% diff
clients/src/test/java/org/apache/kafka/common/protocol/MessageTestUtil.java changed 11.3% diff
clients/src/test/java/org/apache/kafka/common/protocol/types/ProtocolSerializationTest.java changed 3.5% diff
clients/src/test/java/org/apache/kafka/common/protocol/types/StructTest.java changed 4.5% diff
clients/src/test/java/org/apache/kafka/common/record/CompressionRatioEstimatorTest.java added
clients/src/test/java/org/apache/kafka/common/requests/CreateAclsRequestTest.java changed 20.2% diff
clients/src/test/java/org/apache/kafka/common/requests/DeleteAclsRequestTest.java changed 25.7% diff
clients/src/test/java/org/apache/kafka/common/requests/DeleteAclsResponseTest.java changed 68.9% diff
clients/src/test/java/org/apache/kafka/common/requests/DescribeAclsRequestTest.java changed 18.5% diff
clients/src/test/java/org/apache/kafka/common/requests/DescribeAclsResponseTest.java changed 100.0% diff
clients/src/test/java/org/apache/kafka/common/requests/EndTxnRequestTest.java added
clients/src/test/java/org/apache/kafka/common/requests/EndTxnResponseTest.java added
clients/src/test/java/org/apache/kafka/common/requests/JoinGroupRequestTest.java changed 1.4% diff
clients/src/test/java/org/apache/kafka/common/requests/OffsetCommitRequestTest.java changed 7.3% diff
clients/src/test/java/org/apache/kafka/common/requests/OffsetFetchRequestTest.java changed 12.4% diff
clients/src/test/java/org/apache/kafka/common/requests/RequestContextTest.java changed 4.1% diff
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java changed 19.6% diff
clients/src/test/java/org/apache/kafka/common/requests/TxnOffsetCommitRequestTest.java changed 43.3% diff
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorFailureDelayT
est.java
changed 1.6% diff
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java changed 5.1% diff
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticatorTest.ja
va
changed 66.4% diff
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginModuleTest.java changed 2.6% diff
clients/src/test/java/org/apache/kafka/common/security/ssl/SslFactoryTest.java changed 22.5% diff
clients/src/test/java/org/apache/kafka/common/serialization/SerializationTest.java changed 8.5% diff
clients/src/test/java/org/apache/kafka/common/utils/ByteBufferUnmapperTest.java added
clients/src/test/java/org/apache/kafka/common/utils/ByteUtilsTest.java changed 13.0% diff
clients/src/test/java/org/apache/kafka/common/utils/ExitTest.java added
clients/src/test/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollectionTest.java changed 2.5% diff
clients/src/test/java/org/apache/kafka/common/utils/MappedByteBuffersTest.java removed
clients/src/test/java/org/apache/kafka/common/utils/ThreadUtilsTest.java added
clients/src/test/java/org/apache/kafka/common/utils/UtilsTest.java changed 14.9% diff
clients/src/test/java/org/apache/kafka/test/NoRetryException.java added
clients/src/test/java/org/apache/kafka/test/TestCondition.java changed 5.2% diff
clients/src/test/java/org/apache/kafka/test/TestSslUtils.java changed 43.5% diff
clients/src/test/java/org/apache/kafka/test/TestUtils.java changed 4.5% diff
connect/api/src/main/java/org/apache/kafka/connect/data/SchemaBuilder.java changed 1.0% diff
connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeaders.java changed 4.4% diff
connect/api/src/main/java/org/apache/kafka/connect/storage/Converter.java changed 4.0% diff
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java changed 0.3% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java changed 10.8% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatConnector.java changed 21.4% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java changed 0.8% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java changed 26.1% diff
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/Scheduler.java changed 1.5% diff
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnectorTest.java added
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorConfigTest.java changed 11.0% diff
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java changed 0.4% diff
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorHeartBeatConnectorTest.java added
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceConnectorTest.java changed 72.8% diff
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/TestUtils.java added
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java changed 3.2% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java changed 3.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetrics.java changed 3.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocol.java changed 3.8% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java changed 2.7% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java changed 1.1% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Herder.java changed 8.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java changed 3.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ActiveTopicsInfo.java added
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.ja
va
changed 12.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/util/SSLUtils.java changed 11.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitter.java changed 4.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TopicStatus.java added
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java changed 0.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java changed 4.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java changed 2.2% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java changed 2.7% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java changed 6.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java changed 42.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryOffsetBackingStore.java changed 5.1% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryStatusBackingStore.java changed 47.9% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/StatusBackingStore.java changed 31.9% diff
connect/runtime/src/main/java/org/apache/kafka/connect/util/Table.java changed 3.5% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorCientPolicyIntegrationT
est.java
renamed 0.8% diff
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorClientPolicyIntegrationTest.java
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorTopicsIntegrationTest.j
ava
added
connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSinkConnector.java changed 2.9% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.ja
va
changed 3.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java changed 7.2% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoaderTest.
java
changed 91.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResourceTes
t.java
changed 14.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java changed 0.4% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskTest.java changed 2.6% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskThreadedTest.java changed 5.5% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java changed 3.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTaskTest.java changed 10.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTest.java changed 1.6% diff
connect/runtime/src/test/java/org/apache/kafka/connect/storage/FileOffsetBackingStoreTest.java changed 12.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaConfigBackingStoreTest.java changed 0.5% diff
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaStatusBackingStoreFormatTest.ja
va
added
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaStatusBackingStoreTest.java changed 26.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java changed 10.1% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectClusterAssertio
ns.java
changed 20.5% diff
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java changed 0.4% diff
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java changed 3.0% diff
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java changed 1.8% diff
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java changed 2.0% diff
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java changed 0.4% diff
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ValueToKey.java changed 2.0% diff
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/FlattenTest.java changed 8.0% diff
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/InsertFieldTest.java changed 38.6% diff
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ReplaceFieldTest.java changed 1.6% diff
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/SetSchemaMetadataTest.java changed 4.7% diff
examples/src/main/java/kafka/examples/Consumer.java changed 54.7% diff
examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java added
examples/src/main/java/kafka/examples/KafkaConsumerProducerDemo.java changed 64.7% diff
examples/src/main/java/kafka/examples/KafkaExactlyOnceDemo.java added
examples/src/main/java/kafka/examples/KafkaProperties.java changed 22.3% diff
examples/src/main/java/kafka/examples/Producer.java changed 34.7% diff
generator/src/main/java/org/apache/kafka/message/FieldSpec.java changed 8.5% diff
generator/src/main/java/org/apache/kafka/message/FieldType.java changed 5.4% diff
generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java changed 23.2% diff
generator/src/main/java/org/apache/kafka/message/MessageGenerator.java changed 2.1% diff
generator/src/main/java/org/apache/kafka/message/MessageSpecType.java changed 4.9% diff
generator/src/main/java/org/apache/kafka/message/SchemaGenerator.java changed 5.1% diff
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetchsession/FetchSessionBenchmark.java added
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java changed 16.5% diff
streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java added
streams/src/main/java/org/apache/kafka/streams/kstream/CogroupedKStream.java added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java changed 12.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedKStreamImpl.java added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.ja
va
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscrip
tionProcessorSupplier.java
changed 8.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscrip
tionSendProcessorSupplier.java
changed 6.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionStoreRe
ceiveProcessorSupplier.java
changed 8.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSourceNode.java changed 1.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamToTableNode.java added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java changed 0.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java changed 9.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java changed 9.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java changed 1.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java changed 6.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java changed 69.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java changed 5.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java changed 7.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java changed 8.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPassThrough.java renamed 15.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PassThrough.java
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java changed 7.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java changed 8.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java changed 9.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java changed 2.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java changed 5.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java changed 5.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoin.java changed 5.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java changed 5.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java changed 7.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/metrics/Sensors.java removed
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImp
l.java
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java changed 1.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorSu
pplier.java
changed 4.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.j
ava
added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java changed 1.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java changed 1.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java changed 1.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java changed 4.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java changed 1.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java changed 45.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java changed 0.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/Printed.java changed 5.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.java added
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedKStream.java changed 72.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java changed 1.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java added
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java changed 56.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoiner.java changed 9.6% diff
streams/src/main/java/org/apache/kafka/streams/LagInfo.java added
streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java changed 1.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java changed 1.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java changed 0.04% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStandbyTasks.java changed 5.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasks.java changed 0.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java changed 0.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java changed 48.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration
.java
changed 3.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StreamsAssignmentProt
ocolVersions.java
changed 27.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java changed 82.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java changed 7.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicConfig.java changed 10.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java changed 6.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java changed 5.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.jav
a
added
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java changed 29.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java added
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java changed 79.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java changed 12.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java changed 55.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java changed 2.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java changed 9.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java changed 4.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java changed 7.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java changed 3.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java changed 18.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyContextImpl.java changed 21.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java changed 5.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java changed 32.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java changed 0.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java changed 81.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java changed 4.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java changed 15.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java changed 4.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java changed 3.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedChangelogTopicConfig.j
ava
changed 3.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/WindowedChangelogTopicConfig.jav
a
changed 3.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java changed 1.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/UsePartitionTimeOnInvalidTimestamp.java added
streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java changed 4.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java changed 2.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.j
ava
changed 5.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractSegments.java changed 6.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java changed 4.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.ja
va
changed 4.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java changed 3.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java changed 46.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java changed 37.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowedKeyValueIterator.java changed 2.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java changed 39.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreIterator.java changed 3.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/NamedCacheMetrics.java changed 7.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java changed 3.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/Sensors.java removed
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/QueryableStoreProvider.java changed 43.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappingStoreProvider.java changed 36.6% diff
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreTypes.java changed 1.8% diff
streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java changed 69.0% diff
streams/src/main/java/org/apache/kafka/streams/StoreQueryParameters.java added
streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java changed 1.5% diff
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java changed 2.8% diff
streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java changed 84.6% diff
streams/src/test/java/org/apache/kafka/common/metrics/SensorAccessor.java added
streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java changed 0.03% diff
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java changed 17.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/BranchedMultiLevelRepartitionConnectedTo
pologyTest.java
removed
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java changed 10.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableEOSIntegrationTest.java changed 3.9% diff
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableIntegrationTest.java changed 7.7% diff
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java changed 1.0% diff
streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java changed 0.5% diff
streams/src/test/java/org/apache/kafka/streams/integration/LagFetchIntegrationTest.java added
streams/src/test/java/org/apache/kafka/streams/integration/MetricsIntegrationTest.java changed 65.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/OptimizedKTableIntegrationTest.java changed 6.2% diff
streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java changed 42.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java changed 1.7% diff
streams/src/test/java/org/apache/kafka/streams/integration/SmokeTestDriverIntegrationTest.java changed 6.2% diff
streams/src/test/java/org/apache/kafka/streams/integration/StoreQueryIntegrationTest.java added
streams/src/test/java/org/apache/kafka/streams/integration/StoreQuerySuite.java added
streams/src/test/java/org/apache/kafka/streams/integration/StoreUpgradeIntegrationTest.java changed 2.9% diff
streams/src/test/java/org/apache/kafka/streams/integration/StreamStreamJoinIntegrationTest.java changed 1.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/StreamsUpgradeTestIntegrationTest.java added
streams/src/test/java/org/apache/kafka/streams/integration/SuppressionIntegrationTest.java changed 0.8% diff
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java changed 6.8% diff
streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java changed 6.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/AbstractStreamTest.java changed 4.6% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/CogroupedKStreamImplTest.java added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilderTest.java changed 1.6% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImplTest.java changed 10.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java changed 1.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinTest.java changed 31.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregateProce
ssorTest.java
changed 38.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregateTest.java changed 23.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoinTest.java changed 3.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoinTest.java changed 3.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoinTest.java changed 3.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoinTest.java changed 44.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableMapValuesTest.java changed 0.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableSourceTest.java changed 15.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/metrics/TaskMetricsTest.java added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImp
lTest.java
added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorMe
tricsTest.java
changed 77.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SuppressTopologyTest.java changed 8.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImplTe
st.java
added
streams/src/test/java/org/apache/kafka/streams/kstream/MaterializedTest.java changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/RepartitionTopicNamingTest.java changed 29.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfoTest.ja
va
changed 72.7% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/LegacySubscriptionInf
oSerde.java
added
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfoTest.
java
changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStreamThreadTest.java changed 1.9% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicConfigTest.java changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicManagerTest.java changed 43.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java changed 3.3% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetricsTest
.java
added
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImplTest.j
ava
changed 83.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetricsTest.java changed 76.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/MockStreamsMetrics.java changed 9.4% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/PartitionGroupTest.java changed 40.2% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorNodeTest.java changed 42.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java changed 10.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordDeserializerTest.java changed 1.3% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordQueueTest.java changed 18.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionOptimizingTest.java changed 37.9% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionWithMergeOptimizingTe
st.java
changed 14.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/SinkNodeTest.java changed 1.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/SourceNodeTest.java changed 100.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java changed 2.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java changed 26.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java changed 4.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsMetadataStateTest.java changed 61.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.jav
a
changed 43.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java changed 18.7% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java changed 12.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java changed 5.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/UsePartitionTimeOnInvalidTimestampTest.jav
a
added
streams/src/test/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestampTest.java changed 1.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStoreTe
st.java
changed 13.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStoreTest.
java
changed 25.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStoreTest.j
ava
changed 30.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedKeyValueByte
sStoreTest.java
changed 29.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedWindowBytesS
toreTest.java
changed 34.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStoreTest.ja
va
changed 26.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStoreTest.j
ava
changed 14.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStoreTest.ja
va
changed 15.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStoreTest.jav
a
changed 24.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/GlobalStateStoreProviderTest.java changed 1.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemorySessionStoreTest.java changed 1.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueSegmentsTest.java changed 0.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStoreTest.java changed 34.1% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredSessionStoreTest.java changed 27.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStoreTest.
java
changed 27.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStoreTest.ja
va
changed 3.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreTest.java changed 56.1% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/NamedCacheMetricsTest.java changed 1.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderTest.j
ava
changed 0.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetricsTest.java added
streams/src/test/java/org/apache/kafka/streams/state/internals/QueryableStoreProviderTest.java changed 30.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBSessionStoreTest.java changed 3.1% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java changed 1.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreTest.java changed 9.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/SegmentIteratorTest.java changed 1.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionBytesStoreTest.java changed 16.3% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/StoreChangeLoggerTest.java changed 59.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProviderTest.j
ava
changed 32.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferTest.java changed 1.1% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedSegmentsTest.java changed 0.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowBytesStoreTest.java changed 22.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/WrappingStoreProviderTest.java changed 20.0% diff
streams/src/test/java/org/apache/kafka/streams/state/KeyValueStoreTestDriver.java changed 0.3% diff
streams/src/test/java/org/apache/kafka/streams/state/StreamsMetadataTest.java added
streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java changed 4.3% diff
streams/src/test/java/org/apache/kafka/streams/tests/BrokerCompatibilityTest.java changed 0.7% diff
streams/src/test/java/org/apache/kafka/streams/tests/EosTestClient.java changed 8.5% diff
streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java changed 0.4% diff
streams/src/test/java/org/apache/kafka/streams/tests/RelationalSmokeTest.java added
streams/src/test/java/org/apache/kafka/streams/tests/RelationalSmokeTestTest.java added
streams/src/test/java/org/apache/kafka/streams/tests/ShutdownDeadlockTest.java changed 5.8% diff
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java changed 2.8% diff
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java changed 16.3% diff
streams/src/test/java/org/apache/kafka/streams/tests/StaticMemberTestClient.java changed 11.2% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsBrokerDownResilienceTest.java changed 1.8% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsNamedRepartitionTest.java changed 2.2% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java changed 5.5% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java changed 2.3% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsStandByReplicaTest.java changed 1.5% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java changed 28.1% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java changed 1.9% diff
streams/src/test/java/org/apache/kafka/test/InternalMockProcessorContext.java changed 9.9% diff
streams/src/test/java/org/apache/kafka/test/MockInternalProcessorContext.java changed 41.3% diff
streams/src/test/java/org/apache/kafka/test/NoOpRecordCollector.java renamed 51.3% diff
streams/src/test/java/org/apache/kafka/test/MockRecordCollector.java
streams/src/test/java/org/apache/kafka/test/StateStoreProviderStub.java changed 23.1% diff
streams/src/test/java/org/apache/kafka/test/StreamsTestUtils.java changed 11.7% diff
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java changed 1.9% diff
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java changed 2.9% diff
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java changed 1.5% diff
streams/upgrade-system-tests-0100/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.j
ava
changed 12.8% diff
streams/upgrade-system-tests-0100/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCoop
erativeRebalanceTest.java
changed 10.7% diff
streams/upgrade-system-tests-0101/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.j
ava
changed 12.6% diff
streams/upgrade-system-tests-0101/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCoop
erativeRebalanceTest.java
changed 10.7% diff
streams/upgrade-system-tests-0102/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.j
ava
changed 11.1% diff
streams/upgrade-system-tests-0102/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCoop
erativeRebalanceTest.java
changed 7.8% diff
streams/upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.j
ava
changed 11.1% diff
streams/upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCoop
erativeRebalanceTest.java
changed 9.9% diff
streams/upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
changed 11.1% diff
streams/upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooper
ativeRebalanceTest.java
changed 4.8% diff
streams/upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
changed 11.1% diff
streams/upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooper
ativeRebalanceTest.java
changed 4.8% diff
streams/upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
changed 12.5% diff
streams/upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooper
ativeRebalanceTest.java
changed 4.8% diff
streams/upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
changed 12.5% diff
streams/upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooper
ativeRebalanceTest.java
changed 4.8% diff
streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
changed 12.5% diff
streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooper
ativeRebalanceTest.java
changed 4.8% diff
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
changed 12.5% diff
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooper
ativeRebalanceTest.java
changed 5.0% diff
streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
added
tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java changed 44.7% diff
tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java changed 9.9% diff
tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java changed 1.7% diff
tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java changed 9.6% diff
tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java changed 0.8% diff
tools/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java changed 0.2% diff
tools/src/main/java/org/apache/kafka/trogdor/common/ThreadUtils.java moved 2.0% diff
clients/src/main/java/org/apache/kafka/common/utils/ThreadUtils.java
tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java changed 1.2% diff
tools/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java changed 0.4% diff
tools/src/main/java/org/apache/kafka/trogdor/coordinator/TaskManager.java changed 0.2% diff
tools/src/main/java/org/apache/kafka/trogdor/rest/JsonRestServer.java changed 0.4% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressWorker.java changed 1.6% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java changed 0.3% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ExternalCommandWorker.java changed 0.3% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java changed 0.3% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java changed 0.3% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionWorker.java changed 0.9% diff
tools/src/test/java/org/apache/kafka/trogdor/common/MiniTrogdorCluster.java changed 0.4% diff
tools/src/test/java/org/apache/kafka/trogdor/task/SampleTaskWorker.java changed 2.1% diff

Python Programs (40 of 142):

NameStatusDeltaVisual Diff
kafka-merge-pr.py changed 0.4% diff
release.py changed 3.1% diff
tests/kafkatest/__init__.py changed 2.1% diff
tests/kafkatest/services/console_consumer.py changed 12.2% diff
tests/kafkatest/services/kafka/config_property.py changed 1.2% diff
tests/kafkatest/services/kafka/kafka.py changed 19.5% diff
tests/kafkatest/services/monitor/jmx.py changed 7.2% diff
tests/kafkatest/services/performance/streams_performance.py changed 3.3% diff
tests/kafkatest/services/security/security_config.py changed 13.2% diff
tests/kafkatest/services/streams.py changed 4.2% diff
tests/kafkatest/services/transactional_message_copier.py changed 7.1% diff
tests/kafkatest/services/trogdor/kibosh.py changed 3.4% diff
tests/kafkatest/services/verifiable_consumer.py changed 7.5% diff
tests/kafkatest/services/verifiable_producer.py changed 3.7% diff
tests/kafkatest/services/zookeeper.py changed 50.3% diff
tests/kafkatest/tests/client/client_compatibility_features_test.py changed 5.2% diff
tests/kafkatest/tests/client/client_compatibility_produce_consume_test.py changed 5.7% diff
tests/kafkatest/tests/core/compatibility_test_new_broker_test.py changed 5.8% diff
tests/kafkatest/tests/core/downgrade_test.py added
tests/kafkatest/tests/core/fetch_from_follower_test.py changed 7.7% diff
tests/kafkatest/tests/core/group_mode_transactions_test.py added
tests/kafkatest/tests/core/security_rolling_upgrade_test.py changed 2.0% diff
tests/kafkatest/tests/core/throttling_test.py changed 1.6% diff
tests/kafkatest/tests/core/transactions_test.py changed 10.5% diff
tests/kafkatest/tests/core/upgrade_test.py changed 12.7% diff
tests/kafkatest/tests/core/zookeeper_security_upgrade_test.py changed 10.5% diff
tests/kafkatest/tests/core/zookeeper_tls_encrypt_only_test.py added
tests/kafkatest/tests/core/zookeeper_tls_test.py added
tests/kafkatest/tests/end_to_end.py changed 2.0% diff
tests/kafkatest/tests/produce_consume_validate.py changed 4.5% diff
tests/kafkatest/tests/streams/streams_broker_bounce_test.py changed 0.4% diff
tests/kafkatest/tests/streams/streams_broker_compatibility_test.py changed 11.3% diff
tests/kafkatest/tests/streams/streams_cooperative_rebalance_upgrade_test.py changed 1.7% diff
tests/kafkatest/tests/streams/streams_eos_test.py changed 0.4% diff
tests/kafkatest/tests/streams/streams_multiple_rolling_upgrade_test.py removed
tests/kafkatest/tests/streams/streams_relational_smoke_test.py added
tests/kafkatest/tests/streams/streams_standby_replica_test.py changed 74.7% diff
tests/kafkatest/tests/streams/streams_upgrade_test.py changed 6.9% diff
tests/kafkatest/tests/tools/kibosh_test.py changed 15.6% diff
tests/kafkatest/version.py changed 5.2% diff

Shell Programs (5 of 47):

NameStatusDeltaVisual Diff
bin/kafka-run-class.sh changed 6.5% diff
bin/zookeeper-shell.sh changed 19.9% diff
examples/bin/exactly-once-demo.sh added
tests/docker/ducker-ak changed 1.1% diff
vagrant/base.sh changed 2.2% diff

JavaScript Files (all 1):

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

JSON Files (34 of 106):

NameStatusDeltaVisual Diff
clients/src/main/resources/common/message/ApiVersionsRequest.json changed 9.7% diff
clients/src/main/resources/common/message/CreateAclsRequest.json changed 8.5% diff
clients/src/main/resources/common/message/CreateAclsResponse.json changed 10.2% diff
clients/src/main/resources/common/message/CreatePartitionsRequest.json changed 5.0% diff
clients/src/main/resources/common/message/CreatePartitionsResponse.json changed 10.4% diff
clients/src/main/resources/common/message/CreateTopicsResponse.json changed 13.2% diff
clients/src/main/resources/common/message/DeleteAclsRequest.json changed 4.8% diff
clients/src/main/resources/common/message/DeleteAclsResponse.json changed 3.2% diff
clients/src/main/resources/common/message/DeleteTopicsResponse.json changed 4.7% diff
clients/src/main/resources/common/message/DescribeAclsRequest.json changed 14.0% diff
clients/src/main/resources/common/message/DescribeAclsResponse.json changed 8.9% diff
clients/src/main/resources/common/message/DescribeDelegationTokenRequest.json changed 7.0% diff
clients/src/main/resources/common/message/DescribeDelegationTokenResponse.json changed 3.6% diff
clients/src/main/resources/common/message/ExpireDelegationTokenRequest.json changed 8.2% diff
clients/src/main/resources/common/message/ExpireDelegationTokenResponse.json changed 6.6% diff
clients/src/main/resources/common/message/InitProducerIdRequest.json changed 52.8% diff
clients/src/main/resources/common/message/InitProducerIdResponse.json changed 4.2% diff
clients/src/main/resources/common/message/JoinGroupRequest.json changed 2.5% diff
clients/src/main/resources/common/message/JoinGroupResponse.json changed 14.4% diff
clients/src/main/resources/common/message/MetadataResponse.json changed 1.7% diff
clients/src/main/resources/common/message/OffsetFetchRequest.json changed 14.4% diff
clients/src/main/resources/common/message/OffsetFetchResponse.json changed 9.9% diff
clients/src/main/resources/common/message/RenewDelegationTokenRequest.json changed 8.2% diff
clients/src/main/resources/common/message/RenewDelegationTokenResponse.json changed 6.6% diff
clients/src/main/resources/common/message/SaslAuthenticateRequest.json changed 8.9% diff
clients/src/main/resources/common/message/SaslAuthenticateResponse.json changed 12.8% diff
clients/src/main/resources/common/message/SaslHandshakeRequest.json changed 14.8% diff
clients/src/main/resources/common/message/SaslHandshakeResponse.json changed 13.3% diff
clients/src/main/resources/common/message/SyncGroupRequest.json changed 29.5% diff
clients/src/main/resources/common/message/SyncGroupResponse.json changed 29.6% diff
clients/src/main/resources/common/message/TxnOffsetCommitRequest.json changed 25.8% diff
clients/src/main/resources/common/message/TxnOffsetCommitResponse.json changed 10.0% diff
clients/src/test/resources/common/message/SimpleExampleMessage.json changed 97.4% diff
streams/src/main/resources/common/message/SubscriptionInfo.json added

XML Documents (7 of 10):

NameStatusDeltaVisual Diff
checkstyle/import-control-jmh-benchmarks.xml changed 6.1% diff
checkstyle/import-control.xml changed 0.7% diff
checkstyle/suppressions.xml changed 16.1% diff
gradle/spotbugs-exclude.xml changed 17.9% 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/zookeeper-shell.bat changed 18.2% diff

Git Files (1 of 8):

NameStatusDeltaVisual Diff
.gitignore changed 8.4% diff

HTML Pages (17 of 61):

NameStatusDeltaVisual Diff
core/src/main/scala/kafka/admin/AdminUtils.scala changed 0.01%
docs/connect.html changed 4.0%
docs/implementation.html changed 1.8%
docs/introduction.html changed 0.7%
docs/ops.html changed 0.001%
docs/quickstart.html changed 0.1%
docs/security.html changed 9.6%
docs/streams/developer-guide/config-streams.html changed 0.004%
docs/streams/developer-guide/datatypes.html changed 0.9%
docs/streams/developer-guide/dsl-api.html changed 1.5%
docs/streams/developer-guide/interactive-queries.html changed 0.2%
docs/streams/developer-guide/running-app.html changed 0.01%
docs/streams/developer-guide/write-streams.html changed 0.01%
docs/streams/quickstart.html changed 0.1%
docs/streams/upgrade-guide.html changed 2.6%
docs/toc.html changed 4.9%
docs/upgrade.html changed 3.2%

Log Files (15 of 35):

NameStatusDeltaVisual Diff
core/src/main/scala/kafka/log/AbstractIndex.scala changed 2.2% diff
core/src/main/scala/kafka/log/LazyIndex.scala changed 1.0% diff
core/src/main/scala/kafka/log/Log.scala changed 1.1% diff
core/src/main/scala/kafka/log/LogCleaner.scala changed 1.8% diff
core/src/main/scala/kafka/log/LogCleanerManager.scala changed 11.9% diff
core/src/main/scala/kafka/log/LogManager.scala changed 1.8% diff
core/src/main/scala/kafka/log/LogValidator.scala changed 18.2% diff
core/src/main/scala/kafka/log/ProducerStateManager.scala changed 3.8% diff
core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala changed 14.1% diff
core/src/test/scala/unit/kafka/log/LogCleanerTest.scala changed 0.1% diff
core/src/test/scala/unit/kafka/log/LogConfigTest.scala changed 1.7% diff
core/src/test/scala/unit/kafka/log/LogManagerTest.scala changed 2.9% diff
core/src/test/scala/unit/kafka/log/LogTest.scala changed 1.8% diff
core/src/test/scala/unit/kafka/log/LogValidatorTest.scala changed 2.5% diff
core/src/test/scala/unit/kafka/log/ProducerStateManagerTest.scala changed 2.7% diff

Property Files (7 of 47):

NameStatusDeltaVisual Diff
config/connect-mirror-maker.properties changed 74.8% diff
config/server.properties changed 0.6% diff
gradle.properties changed 1.4% diff
gradle/wrapper/gradle-wrapper.properties changed 76.6% diff
tests/kafkatest/services/kafka/templates/kafka.properties changed 19.0% diff
tests/kafkatest/services/templates/zookeeper.properties changed 54.9% diff
tests/kafkatest/tests/streams/templates/log4j_template.properties added

Directories (25 of 799):

NameStatus
clients/src/main/java/org/apache/kafka/common/metrics/internals added
clients/src/test/java/org/apache/kafka/common/metrics/internals added
core/src/main/scala/org added
core/src/main/scala/org/apache added
core/src/main/scala/org/apache/zookeeper added
core/src/test/scala/kafka/server added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetchsession added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/metrics moved
streams/src/test/java/org/apache/kafka/streams/kstream/internals/metrics
streams/src/main/resources added
streams/src/main/resources/common added
streams/src/main/resources/common/message added
streams/src/test/java/org/apache/kafka/common added
streams/src/test/java/org/apache/kafka/common/metrics added
streams/upgrade-system-tests-24 added
streams/upgrade-system-tests-24/src added
streams/upgrade-system-tests-24/src/test added
streams/upgrade-system-tests-24/src/test/java added
streams/upgrade-system-tests-24/src/test/java/org added
streams/upgrade-system-tests-24/src/test/java/org/apache added
streams/upgrade-system-tests-24/src/test/java/org/apache/kafka added
streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams added
streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests added
tests/kafkatest/tests/streams/templates added

Readme Files (3 of 7):

NameStatusDeltaVisual Diff
clients/src/main/resources/common/message/README.md changed 5.9% diff
examples/README changed 100.0% diff
README.md changed 2.4% diff

Text Files (181 of 395):

NameStatusDeltaVisual Diff
build.gradle changed 6.0% diff
core/src/main/scala/kafka/api/ApiUtils.scala changed 8.7% diff
core/src/main/scala/kafka/api/ApiVersion.scala changed 2.1% diff
core/src/main/scala/kafka/cluster/Partition.scala changed 11.3% diff
core/src/main/scala/kafka/common/RecordValidationException.scala changed 11.3% diff
core/src/main/scala/kafka/controller/ControllerChannelManager.scala changed 4.5% diff
core/src/main/scala/kafka/controller/ControllerEventManager.scala changed 6.0% diff
core/src/main/scala/kafka/controller/ControllerState.scala changed 13.4% diff
core/src/main/scala/kafka/controller/KafkaController.scala changed 4.2% diff
core/src/main/scala/kafka/controller/ReplicaStateMachine.scala changed 3.0% diff
core/src/main/scala/kafka/controller/TopicDeletionManager.scala changed 21.1% diff
core/src/main/scala/kafka/coordinator/group/DelayedHeartbeat.scala changed 16.6% diff
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala changed 20.9% diff
core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala changed 9.0% diff
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala changed 3.9% diff
core/src/main/scala/kafka/coordinator/group/MemberMetadata.scala changed 12.6% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala changed 11.4% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala changed 3.4% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala changed 2.0% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandler.scala changed 1.3% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala changed 30.7% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala changed 1.6% diff
core/src/main/scala/kafka/message/CompressionCodec.scala changed 4.8% diff
core/src/main/scala/kafka/metrics/KafkaMetricsConfig.scala changed 16.5% diff
core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala changed 17.5% diff
core/src/main/scala/kafka/network/SocketServer.scala changed 6.0% diff
core/src/main/scala/kafka/security/auth/Acl.scala changed 42.1% diff
core/src/main/scala/kafka/security/auth/Operation.scala changed 34.3% diff
core/src/main/scala/kafka/security/auth/PermissionType.scala changed 18.3% diff
core/src/main/scala/kafka/security/auth/Resource.scala changed 9.0% diff
core/src/main/scala/kafka/security/auth/ResourceType.scala changed 17.9% diff
core/src/main/scala/kafka/security/auth/SimpleAclAuthorizer.scala changed 6.6% diff
core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala changed 30.8% diff
core/src/main/scala/kafka/security/authorizer/AclEntry.scala added
core/src/main/scala/kafka/security/authorizer/AuthorizerUtils.scala changed 58.7% diff
core/src/main/scala/kafka/security/authorizer/AuthorizerWrapper.scala changed 41.1% diff
core/src/main/scala/kafka/server/AbstractFetcherManager.scala changed 19.4% diff
core/src/main/scala/kafka/server/AbstractFetcherThread.scala changed 21.6% diff
core/src/main/scala/kafka/server/AdminManager.scala changed 7.1% diff
core/src/main/scala/kafka/server/ClientQuotaManager.scala changed 3.0% diff
core/src/main/scala/kafka/server/DelayedCreatePartitions.scala changed 9.0% diff
core/src/main/scala/kafka/server/DelayedFetch.scala changed 2.1% diff
core/src/main/scala/kafka/server/DelayedFuture.scala changed 4.0% diff
core/src/main/scala/kafka/server/DelayedOperation.scala changed 1.7% diff
core/src/main/scala/kafka/server/FetchSession.scala changed 7.1% diff
core/src/main/scala/kafka/server/KafkaApis.scala changed 11.8% diff
core/src/main/scala/kafka/server/KafkaConfig.scala changed 13.4% diff
core/src/main/scala/kafka/server/KafkaRequestHandler.scala changed 22.6% diff
core/src/main/scala/kafka/server/KafkaServer.scala changed 9.2% diff
core/src/main/scala/kafka/server/MetadataCache.scala changed 20.1% diff
core/src/main/scala/kafka/server/ReplicaAlterLogDirsManager.scala changed 46.2% diff
core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala changed 13.8% diff
core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala changed 1.7% diff
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala changed 9.5% diff
core/src/main/scala/kafka/server/ReplicaManager.scala changed 3.2% diff
core/src/main/scala/kafka/utils/CoreUtils.scala changed 9.0% diff
core/src/main/scala/kafka/utils/Exit.scala changed 18.4% diff
core/src/main/scala/kafka/utils/json/DecodeJson.scala changed 25.5% diff
core/src/main/scala/kafka/utils/KafkaScheduler.scala changed 6.6% diff
core/src/main/scala/kafka/utils/Pool.scala changed 4.2% diff
core/src/main/scala/kafka/utils/timer/Timer.scala changed 7.1% diff
core/src/main/scala/kafka/zk/KafkaZkClient.scala changed 1.4% diff
core/src/main/scala/kafka/zk/ZkData.scala changed 6.0% diff
core/src/main/scala/kafka/zookeeper/ZooKeeperClient.scala changed 13.3% diff
core/src/test/scala/integration/kafka/admin/ReassignPartitionsIntegrationTest.scala changed 100.0% diff
core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala removed
core/src/test/scala/integration/kafka/api/AdminClientWithPoliciesIntegrationTest.scala changed 4.7% diff
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala changed 13.2% diff
core/src/test/scala/integration/kafka/api/BaseAdminIntegrationTest.scala added
core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala changed 1.3% diff
core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala changed 9.2% diff
core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala changed 2.8% diff
core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala changed 2.8% diff
core/src/test/scala/integration/kafka/api/DelegationTokenEndToEndAuthorizationTest.scala changed 2.5% diff
core/src/test/scala/integration/kafka/api/DescribeAuthorizedOperationsTest.scala changed 16.1% diff
core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala changed 4.9% diff
core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala changed 2.4% diff
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala added
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala changed 0.4% diff
core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala changed 90.0% diff
core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala changed 1.3% diff
core/src/test/scala/integration/kafka/api/SaslGssapiSslEndToEndAuthorizationTest.scala changed 10.3% diff
core/src/test/scala/integration/kafka/api/SaslPlainPlaintextConsumerTest.scala changed 7.3% diff
core/src/test/scala/integration/kafka/api/SaslSslAdminClientIntegrationTest.scala removed
core/src/test/scala/integration/kafka/api/SaslSslAdminIntegrationTest.scala added
core/src/test/scala/integration/kafka/api/SslAdminClientIntegrationTest.scala removed
core/src/test/scala/integration/kafka/api/SslAdminIntegrationTest.scala added
core/src/test/scala/integration/kafka/api/SslEndToEndAuthorizationTest.scala changed 15.8% diff
core/src/test/scala/integration/kafka/api/TransactionsBounceTest.scala changed 10.9% diff
core/src/test/scala/integration/kafka/api/TransactionsExpirationTest.scala added
core/src/test/scala/integration/kafka/api/TransactionsTest.scala changed 29.3% diff
core/src/test/scala/integration/kafka/network/DynamicConnectionQuotaTest.scala changed 10.7% diff
core/src/test/scala/integration/kafka/server/DelayedFetchTest.scala changed 3.2% diff
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala changed 0.4% diff
core/src/test/scala/integration/kafka/server/GssapiAuthenticationTest.scala changed 2.3% diff
core/src/test/scala/kafka/security/minikdc/MiniKdc.scala changed 1.4% diff
core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala changed 16.0% diff
core/src/test/scala/unit/kafka/admin/DelegationTokenCommandTest.scala changed 2.1% diff
core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala changed 8.2% diff
core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala changed 9.3% diff
core/src/test/scala/unit/kafka/cluster/AssignmentStateTest.scala added
core/src/test/scala/unit/kafka/cluster/PartitionLockTest.scala added
core/src/test/scala/unit/kafka/common/ZkNodeChangeNotificationListenerTest.scala changed 16.0% diff
core/src/test/scala/unit/kafka/controller/MockPartitionStateMachine.scala changed 6.3% diff
core/src/test/scala/unit/kafka/controller/MockReplicaStateMachine.scala changed 21.6% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorConcurrencyTest.scala changed 4.8% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorConcurrencyTest.scala changed 76.3% diff
core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala changed 11.0% diff
core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala changed 0.7% diff
core/src/test/scala/unit/kafka/security/auth/AclTest.scala removed
core/src/test/scala/unit/kafka/security/auth/SimpleAclAuthorizerTest.scala changed 1.8% diff
core/src/test/scala/unit/kafka/security/auth/ZkAuthorizationTest.scala changed 1.1% diff
core/src/test/scala/unit/kafka/security/authorizer/AclAuthorizerTest.scala changed 23.5% diff
core/src/test/scala/unit/kafka/security/authorizer/AclEntryTest.scala added
core/src/test/scala/unit/kafka/security/token/delegation/DelegationTokenManagerTest.scala changed 1.3% diff
core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala added
core/src/test/scala/unit/kafka/server/AbstractCreateTopicsRequestTest.scala changed 22.2% diff
core/src/test/scala/unit/kafka/server/AddPartitionsToTxnRequestTest.scala changed 14.6% diff
core/src/test/scala/unit/kafka/server/AlterReplicaLogDirsRequestTest.scala changed 7.2% diff
core/src/test/scala/unit/kafka/server/ApiVersionsRequestTest.scala changed 50.5% diff
core/src/test/scala/unit/kafka/server/BaseRequestTest.scala changed 64.4% diff
core/src/test/scala/unit/kafka/server/CreateTopicsRequestTest.scala changed 23.2% diff
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsOnPlainTextTest.scala changed 4.7% diff
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsTest.scala changed 3.3% diff
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsWithDisableTokenFeatureTest.scala changed 3.8% diff
core/src/test/scala/unit/kafka/server/DeleteTopicsRequestTest.scala changed 10.0% diff
core/src/test/scala/unit/kafka/server/DeleteTopicsRequestWithDeletionDisabledTest.scala changed 15.1% diff
core/src/test/scala/unit/kafka/server/DescribeLogDirsRequestTest.scala changed 9.0% diff
core/src/test/scala/unit/kafka/server/epoch/EpochDrivenReplicationProtocolAcceptanceTest.scala changed 5.1% diff
core/src/test/scala/unit/kafka/server/FetchRequestDownConversionConfigTest.scala changed 2.7% diff
core/src/test/scala/unit/kafka/server/FetchRequestMaxBytesTest.scala added
core/src/test/scala/unit/kafka/server/FetchRequestTest.scala changed 10.3% diff
core/src/test/scala/unit/kafka/server/KafkaMetricReporterExceptionHandlingTest.scala changed 9.1% diff
core/src/test/scala/unit/kafka/server/KafkaServerTest.scala changed 100.0% diff
core/src/test/scala/unit/kafka/server/ListOffsetsRequestTest.scala changed 4.3% diff
core/src/test/scala/unit/kafka/server/LogDirFailureTest.scala changed 0.8% diff
core/src/test/scala/unit/kafka/server/LogOffsetTest.scala changed 7.8% diff
core/src/test/scala/unit/kafka/server/MetadataRequestTest.scala changed 17.4% diff
core/src/test/scala/unit/kafka/server/OffsetsForLeaderEpochRequestTest.scala changed 3.7% diff
core/src/test/scala/unit/kafka/server/ProduceRequestTest.scala changed 8.2% diff
core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala changed 22.5% diff
core/src/test/scala/unit/kafka/server/SaslApiVersionsRequestTest.scala changed 50.6% diff
core/src/test/scala/unit/kafka/server/StopReplicaRequestTest.scala changed 12.1% diff
core/src/test/scala/unit/kafka/utils/MockScheduler.scala changed 3.9% diff
core/src/test/scala/unit/kafka/utils/TestUtils.scala changed 6.0% diff
core/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala changed 6.1% diff
core/src/test/scala/unit/kafka/zk/ZooKeeperTestHarness.scala changed 2.2% diff
core/src/test/scala/unit/kafka/zookeeper/ZooKeeperClientTest.scala changed 4.6% diff
gradle/dependencies.gradle changed 14.2% diff
gradlew changed 8.7% diff
settings.gradle changed 2.5% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionConversions.scala changed 48.2% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionsCompatConversions.scal
a
changed 58.4% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/ImplicitConversions.scala changed 39.6% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/CogroupedKStream.scala added
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Grouped.scala changed 0.1% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KGroupedStream.scala changed 28.9% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KGroupedTable.scala changed 12.8% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala changed 22.9% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KTable.scala changed 10.7% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/SessionWindowedCogroupe
dKStream.scala
added
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/SessionWindowedKStream.
scala
changed 20.1% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/StreamJoined.scala changed 8.3% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Suppressed.scala changed 4.8% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/TimeWindowedCogroupedKS
tream.scala
added
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/TimeWindowedKStream.sca
la
changed 16.4% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala changed 2.8% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala changed 5.4% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/ConsumedTest.scala changed 1.3% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/GroupedTest.scala changed 2.2% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/JoinedTest.scala changed 2.3% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala changed 9.4% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KTableTest.scala changed 4.4% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/MaterializedTest.scala changed 1.1% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/ProducedTest.scala changed 2.0% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/StreamJoinedTest.scala changed 1.4% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/SuppressedTest.scala changed 4.2% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinScalaIntegrati
onTestImplicitSerdes.scala
changed 18.0% diff
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/WordCountTest.scala changed 9.9% diff
tests/docker/Dockerfile changed 6.1% diff
wrapper.gradle changed 30.5% diff

Packages Compared:

kafka-2.4.1-src.tgz
kafka-2.5.0-src.tgz


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