"Fossies" - the Fresh Open Source Software Archive  

Source code changes report for "Apache kafka" between the packages
kafka-2.1.1-src.tgz and kafka-2.2.0-src.tgz

About: Apache kafka is a distributed streaming platform.

Summary:

The "Apache kafka" source code changed by about 7.9% and now consists of 2967 regular files (+174) and 667 directories (+27).

Related Informations:

None found by Fossies.

Changes In Files (According File Type):

File TypeTotalAddedRemovedChanged
C program 96 0 0 52
Java program 1993 80 9 546
Python program 126 6 0 21
Shell program 46 0 3 3
Ruby program 1 0 0 0
Configuration file 7 0 0 1
JavaScript file 1 0 0 1
JSON file 94 94 0 0
XML document 9 0 0 7
DOS Batch file 23 0 0 1
Git file 8 0 0 2
HTML page 58 0 0 17
Property file 41 0 0 1
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 668 28 1 0
Information file 3 0 0 0
License 1 0 0 0
Readme file 6 1 0 1
Text file 414 7 2 132
Other 2 0 0 0
Total Files364921615785



C Programs (52 of 96):

NameStatusDeltaVisual Diff
core/src/main/scala/kafka/admin/AclCommand.scala changed 1.7% diff
core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala changed 11.3% diff
core/src/main/scala/kafka/admin/ConfigCommand.scala changed 1.5% diff
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala changed 1.7% diff
core/src/main/scala/kafka/admin/DelegationTokenCommand.scala changed 3.6% diff
core/src/main/scala/kafka/admin/DeleteRecordsCommand.scala changed 8.7% diff
core/src/main/scala/kafka/admin/LogDirsCommand.scala changed 6.5% diff
core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala changed 100.0% diff
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala changed 2.3% diff
core/src/main/scala/kafka/admin/TopicCommand.scala changed 100.0% diff
core/src/main/scala/kafka/admin/ZkSecurityMigrator.scala changed 28.9% diff
core/src/main/scala/kafka/controller/ControllerContext.scala changed 23.4% diff
core/src/main/scala/kafka/log/LogConfig.scala changed 0.5% diff
core/src/main/scala/kafka/network/RequestChannel.scala changed 2.6% diff
core/src/main/scala/kafka/tools/ConsoleConsumer.scala changed 6.2% diff
core/src/main/scala/kafka/tools/ConsoleProducer.scala changed 15.0% diff
core/src/main/scala/kafka/tools/ConsumerPerformance.scala changed 4.3% diff
core/src/main/scala/kafka/tools/DumpLogSegments.scala changed 31.9% diff
core/src/main/scala/kafka/tools/MirrorMaker.scala changed 32.3% diff
core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala changed 1.4% diff
core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala changed 20.4% diff
core/src/test/scala/kafka/common/InterBrokerSendThreadTest.scala changed 2.4% diff
core/src/test/scala/kafka/tools/LogCompactionTester.scala changed 1.4% diff
core/src/test/scala/other/kafka/ReplicationQuotasTestRig.scala changed 0.4% diff
core/src/test/scala/other/kafka/StressTestLog.scala changed 1.1% diff
core/src/test/scala/unit/kafka/admin/ResetConsumerGroupOffsetTest.scala changed 1.4% diff
core/src/test/scala/unit/kafka/api/ApiVersionTest.scala changed 14.7% diff
core/src/test/scala/unit/kafka/cluster/PartitionTest.scala changed 35.3% diff
core/src/test/scala/unit/kafka/cluster/ReplicaTest.scala changed 1.2% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala changed 1.1% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerChannelManagerTest.scala changed 4.7% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandlerTes
t.scala
changed 2.7% diff
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionStateManagerTest.scala changed 0.2% diff
core/src/test/scala/unit/kafka/KafkaConfigTest.scala changed 15.1% diff
core/src/test/scala/unit/kafka/log/LogManagerTest.scala changed 7.8% diff
core/src/test/scala/unit/kafka/log/LogTest.scala changed 1.4% diff
core/src/test/scala/unit/kafka/log/LogValidatorTest.scala changed 9.7% diff
core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala changed 8.4% diff
core/src/test/scala/unit/kafka/server/epoch/LeaderEpochFileCacheTest.scala changed 0.2% diff
core/src/test/scala/unit/kafka/server/FetchSessionTest.scala changed 6.3% diff
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala changed 18.4% diff
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala changed 3.7% diff
core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala changed 4.6% diff
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala changed 2.1% diff
core/src/test/scala/unit/kafka/server/ReplicaFetcherThreadTest.scala changed 3.1% diff
core/src/test/scala/unit/kafka/server/ReplicaManagerQuotasTest.scala changed 0.5% diff
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala changed 3.9% diff
core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala changed 0.6% diff
core/src/test/scala/unit/kafka/tools/ConsoleConsumerTest.scala changed 12.7% diff
core/src/test/scala/unit/kafka/tools/ConsoleProducerTest.scala changed 5.5% diff
core/src/test/scala/unit/kafka/tools/DumpLogSegmentsTest.scala changed 20.6% diff
core/src/test/scala/unit/kafka/utils/CommandLineUtilsTest.scala changed 100.0% diff

Java Programs (635 of 1993):

NameStatusDeltaVisual Diff
clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java changed 13.4% diff
clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java changed 0.2% diff
clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersOptions.java added
clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersResult.java added
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java changed 2.7% diff
clients/src/main/java/org/apache/kafka/clients/ClientUtils.java changed 10.2% diff
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java changed 2.1% diff
clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java changed 2.4% diff
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java changed 0.3% diff
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerInterceptor.java changed 1.8% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java changed 6.9% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java changed 0.6% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java changed 1.6% diff
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java changed 8.7% diff
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java changed 6.4% diff
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java changed 1.3% diff
clients/src/main/java/org/apache/kafka/clients/consumer/RoundRobinAssignor.java changed 32.4% diff
clients/src/main/java/org/apache/kafka/clients/consumer/StickyAssignor.java changed 1.8% diff
clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java changed 1.7% diff
clients/src/main/java/org/apache/kafka/clients/Metadata.java changed 53.6% diff
clients/src/main/java/org/apache/kafka/clients/MetadataCache.java added
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java changed 2.0% diff
clients/src/main/java/org/apache/kafka/clients/producer/Callback.java changed 21.5% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java changed 0.2% diff
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java changed 0.1% diff
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java changed 1.0% diff
clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java changed 0.7% diff
clients/src/main/java/org/apache/kafka/clients/producer/Producer.java changed 8.3% diff
clients/src/main/java/org/apache/kafka/common/acl/AclOperation.java changed 14.3% diff
clients/src/main/java/org/apache/kafka/common/Cluster.java changed 27.9% diff
clients/src/main/java/org/apache/kafka/common/ClusterResource.java changed 21.8% diff
clients/src/main/java/org/apache/kafka/common/config/internals/BrokerSecurityConfigs.java changed 38.8% diff
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java changed 3.8% diff
clients/src/main/java/org/apache/kafka/common/errors/GroupMaxSizeReachedException.java added
clients/src/main/java/org/apache/kafka/common/errors/MemberIdRequiredException.java added
clients/src/main/java/org/apache/kafka/common/errors/OffsetNotAvailableException.java added
clients/src/main/java/org/apache/kafka/common/errors/PreferredLeaderNotAvailableException.java added
clients/src/main/java/org/apache/kafka/common/errors/StaleBrokerEpochException.java added
clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java changed 1.9% diff
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java changed 2.9% diff
clients/src/main/java/org/apache/kafka/common/internals/Topic.java changed 2.3% diff
clients/src/main/java/org/apache/kafka/common/metrics/MetricsReporter.java changed 3.9% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/Avg.java changed 3.8% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/Max.java changed 10.7% diff
clients/src/main/java/org/apache/kafka/common/metrics/stats/Min.java changed 10.8% diff
clients/src/main/java/org/apache/kafka/common/network/Authenticator.java changed 100.0% diff
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilders.java changed 9.6% diff
clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java changed 74.0% diff
clients/src/main/java/org/apache/kafka/common/network/PlaintextChannelBuilder.java changed 9.2% diff
clients/src/main/java/org/apache/kafka/common/network/ReauthenticationContext.java added
clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java changed 15.7% diff
clients/src/main/java/org/apache/kafka/common/network/Selector.java changed 9.1% diff
clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java changed 12.7% diff
clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java changed 0.1% diff
clients/src/main/java/org/apache/kafka/common/PartitionInfo.java changed 6.0% diff
clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java changed 4.9% diff
clients/src/main/java/org/apache/kafka/common/protocol/ApiMessage.java added
clients/src/main/java/org/apache/kafka/common/protocol/ByteBufferAccessor.java added
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java changed 4.9% diff
clients/src/main/java/org/apache/kafka/common/protocol/Message.java added
clients/src/main/java/org/apache/kafka/common/protocol/MessageUtil.java added
clients/src/main/java/org/apache/kafka/common/protocol/Readable.java added
clients/src/main/java/org/apache/kafka/common/protocol/types/Struct.java changed 4.9% diff
clients/src/main/java/org/apache/kafka/common/protocol/Writable.java added
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java changed 5.7% diff
clients/src/main/java/org/apache/kafka/common/record/LazyDownConversionRecords.java changed 4.1% diff
clients/src/main/java/org/apache/kafka/common/record/LazyDownConversionRecordsSend.java changed 4.6% diff
clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java changed 0.2% diff
clients/src/main/java/org/apache/kafka/common/record/MultiRecordsSend.java changed 2.4% diff
clients/src/main/java/org/apache/kafka/common/requests/AbstractControlRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java changed 1.3% 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/ControlledShutdownRequest.java changed 35.2% diff
clients/src/main/java/org/apache/kafka/common/requests/ControlledShutdownResponse.java changed 4.8% diff
clients/src/main/java/org/apache/kafka/common/requests/ElectPreferredLeadersRequest.java added
clients/src/main/java/org/apache/kafka/common/requests/ElectPreferredLeadersResponse.java added
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java changed 2.8% diff
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java changed 4.1% diff
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java changed 64.2% diff
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrResponse.java changed 13.4% diff
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupRequest.java changed 60.1% diff
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupResponse.java changed 56.1% diff
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java changed 1.7% diff
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java changed 3.2% diff
clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java changed 2.8% diff
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java changed 0.7% diff
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateRequest.java changed 6.7% diff
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateResponse.java changed 33.0% diff
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaRequest.java changed 57.6% diff
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaResponse.java changed 13.3% diff
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataRequest.java changed 58.9% diff
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataResponse.java changed 8.0% diff
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipal.java changed 9.7% diff
clients/src/main/java/org/apache/kafka/common/security/authenticator/CredentialCache.java changed 1.6% diff
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultKafkaPrincipalBuilder.j
ava
changed 19.9% diff
clients/src/main/java/org/apache/kafka/common/security/authenticator/LoginManager.java changed 0.4% diff
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java changed 60.2% diff
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientCallbackHandler.java changed 0.9% diff
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslInternalConfigs.java added
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java changed 53.1% diff
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCrede
ntialRefreshingLogin.java
changed 3.5% diff
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslServer.
java
changed 2.2% diff
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginModule.java changed 5.1% diff
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslServer.java changed 3.6% diff
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramServerCallbackHandler.j
ava
changed 8.3% diff
clients/src/main/java/org/apache/kafka/common/security/ssl/SslPrincipalMapper.java added
clients/src/main/java/org/apache/kafka/common/security/token/delegation/internals/DelegationTokenCa
che.java
changed 16.6% diff
clients/src/main/java/org/apache/kafka/common/security/token/delegation/internals/DelegationTokenCr
edentialCallback.java
changed 21.4% diff
clients/src/main/java/org/apache/kafka/common/utils/AppInfoParser.java changed 5.0% diff
clients/src/main/java/org/apache/kafka/common/utils/Bytes.java changed 1.0% diff
clients/src/main/java/org/apache/kafka/common/utils/CollectionUtils.java changed 4.8% diff
clients/src/main/java/org/apache/kafka/common/utils/Crc32.java changed 0.1% diff
clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashMultiSet.java added
clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashSet.java changed 59.4% diff
clients/src/main/java/org/apache/kafka/common/utils/PureJavaCrc32C.java changed 0.1% diff
clients/src/main/java/org/apache/kafka/common/utils/Utils.java changed 2.0% diff
clients/src/main/java/org/apache/kafka/server/policy/AlterConfigPolicy.java changed 9.0% diff
clients/src/main/java/org/apache/kafka/server/policy/CreateTopicPolicy.java changed 5.6% diff
clients/src/test/java/org/apache/kafka/clients/admin/AdminClientUnitTestEnv.java changed 38.5% diff
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java changed 10.1% diff
clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java changed 2.4% diff
clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java changed 4.6% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java changed 10.6% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java changed 5.9% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClientTest.java changed 0.9% diff
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java changed 4.7% diff
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java changed 13.4% diff
clients/src/test/java/org/apache/kafka/clients/FetchSessionHandlerTest.java changed 0.1% diff
clients/src/test/java/org/apache/kafka/clients/MetadataTest.java changed 75.5% diff
clients/src/test/java/org/apache/kafka/clients/MockClient.java changed 17.3% diff
clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java changed 1.4% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java changed 5.3% diff
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java changed 6.1% diff
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java changed 9.9% diff
clients/src/test/java/org/apache/kafka/common/config/ConfigDefTest.java changed 0.2% diff
clients/src/test/java/org/apache/kafka/common/KafkaFutureTest.java changed 13.8% diff
clients/src/test/java/org/apache/kafka/common/message/MessageTest.java added
clients/src/test/java/org/apache/kafka/common/metrics/JmxReporterTest.java changed 1.8% diff
clients/src/test/java/org/apache/kafka/common/metrics/MetricsTest.java changed 3.2% diff
clients/src/test/java/org/apache/kafka/common/network/ChannelBuildersTest.java changed 8.6% diff
clients/src/test/java/org/apache/kafka/common/network/NetworkTestUtils.java changed 18.2% diff
clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java changed 45.8% diff
clients/src/test/java/org/apache/kafka/common/network/SaslChannelBuilderTest.java changed 3.2% diff
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java changed 10.7% diff
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java changed 1.0% diff
clients/src/test/java/org/apache/kafka/common/protocol/ApiKeysTest.java changed 6.7% diff
clients/src/test/java/org/apache/kafka/common/protocol/MessageUtilTest.java added
clients/src/test/java/org/apache/kafka/common/record/FileRecordsTest.java changed 13.5% diff
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsBuilderTest.java changed 1.0% diff
clients/src/test/java/org/apache/kafka/common/requests/ControlRequestTest.java added
clients/src/test/java/org/apache/kafka/common/requests/LeaderAndIsrResponseTest.java changed 2.1% diff
clients/src/test/java/org/apache/kafka/common/requests/RequestContextTest.java changed 4.4% diff
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java changed 8.1% diff
clients/src/test/java/org/apache/kafka/common/requests/StopReplicaResponseTest.java changed 5.1% diff
clients/src/test/java/org/apache/kafka/common/security/auth/DefaultKafkaPrincipalBuilderTest.java changed 40.7% diff
clients/src/test/java/org/apache/kafka/common/security/authenticator/ClientAuthenticationFailureTes
t.java
changed 0.8% diff
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorFailureDelayT
est.java
changed 0.9% diff
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java changed 33.1% diff
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticatorTest.ja
va
changed 3.2% diff
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCrede
ntialRefreshingLoginTest.java
changed 13.9% diff
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslServerT
est.java
changed 5.1% diff
clients/src/test/java/org/apache/kafka/common/security/ssl/SslPrincipalMapperTest.java added
clients/src/test/java/org/apache/kafka/common/security/TestSecurityConfig.java changed 7.8% diff
clients/src/test/java/org/apache/kafka/common/serialization/SerializationTest.java changed 4.4% diff
clients/src/test/java/org/apache/kafka/common/utils/ImplicitLinkedHashMultiSetTest.java added
clients/src/test/java/org/apache/kafka/common/utils/ImplicitLinkedHashSetTest.java changed 8.2% diff
clients/src/test/java/org/apache/kafka/test/TestCondition.java changed 2.1% diff
clients/src/test/java/org/apache/kafka/test/TestSslUtils.java changed 0.3% diff
clients/src/test/java/org/apache/kafka/test/TestUtils.java changed 38.2% diff
connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java changed 5.1% diff
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java changed 3.1% diff
connect/api/src/main/java/org/apache/kafka/connect/data/Values.java changed 0.6% diff
connect/api/src/test/java/org/apache/kafka/connect/connector/ConnectorReconfigurationTest.java changed 4.8% diff
connect/api/src/test/java/org/apache/kafka/connect/data/SchemaProjectorTest.java changed 6.0% diff
connect/api/src/test/java/org/apache/kafka/connect/data/ValuesTest.java changed 22.7% diff
connect/api/src/test/java/org/apache/kafka/connect/util/ConnectorUtilsTest.java changed 3.9% diff
connect/basic-auth-extension/src/test/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasB
asicAuthFilterTest.java
changed 0.7% diff
connect/json/src/test/java/org/apache/kafka/connect/json/JsonConverterTest.java changed 0.7% diff
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java changed 2.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/converters/NumberConverter.java changed 0.7% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetrics.java changed 0.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java changed 2.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java changed 1.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java changed 2.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.ja
va
changed 0.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java changed 1.6% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java changed 1.4% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/ConnectRestConfigurable.java changed 12.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java changed 0.9% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/util/SSLUtils.java changed 0.5% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java changed 8.9% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java changed 0.6% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java changed 1.1% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java changed 4.0% diff
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java changed 0.3% diff
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageWriter.java changed 0.4% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractHerderTest.java changed 0.7% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ConnectMetricsTest.java changed 0.5% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.ja
va
changed 0.4% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorTest.ja
va
changed 1.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java changed 2.1% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginDescTest.java changed 4.0% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginsTest.java changed 0.6% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginUtilsTest.java changed 2.2% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/MockConnectMetrics.java changed 0.4% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResou
rceTest.java
changed 20.7% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/RestServerTest.java changed 30.6% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/util/SSLUtilsTest.java changed 0.5% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitterTest.java changed 4.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java changed 0.5% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConfigTransformerTest.java changed 4.7% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskTest.java changed 1.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskThreadedTest.java changed 2.5% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java changed 1.7% diff
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTest.java changed 9.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/storage/FileOffsetBackingStoreTest.java changed 0.8% diff
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaConfigBackingStoreTest.java changed 1.6% diff
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java changed 5.9% diff
connect/runtime/src/test/java/org/apache/kafka/connect/storage/OffsetStorageWriterTest.java changed 0.5% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java changed 1.2% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/KafkaBasedLogTest.java changed 0.3% diff
connect/runtime/src/test/java/org/apache/kafka/connect/util/TopicAdminTest.java changed 4.3% diff
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java changed 1.4% diff
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampRouter.java changed 2.4% diff
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/FlattenTest.java changed 1.0% diff
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/MaskFieldTest.java changed 0.6% diff
core/src/main/scala/kafka/tools/StreamsResetter.java changed 18.0% diff
examples/src/main/java/kafka/examples/Producer.java changed 5.4% diff
generator/src/main/java/org/apache/kafka/message/ApiMessageFactoryGenerator.java added
generator/src/main/java/org/apache/kafka/message/CodeBuffer.java added
generator/src/main/java/org/apache/kafka/message/FieldSpec.java added
generator/src/main/java/org/apache/kafka/message/FieldType.java added
generator/src/main/java/org/apache/kafka/message/HeaderGenerator.java added
generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java added
generator/src/main/java/org/apache/kafka/message/MessageGenerator.java added
generator/src/main/java/org/apache/kafka/message/MessageSpec.java added
generator/src/main/java/org/apache/kafka/message/MessageSpecType.java added
generator/src/main/java/org/apache/kafka/message/SchemaGenerator.java added
generator/src/main/java/org/apache/kafka/message/StructSpec.java added
generator/src/main/java/org/apache/kafka/message/Versions.java added
generator/src/test/java/org/apache/kafka/message/MessageGeneratorTest.java added
generator/src/test/java/org/apache/kafka/message/VersionsTest.java added
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerRecordBenchmark.java changed 3.3% diff
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java changed 1.2% diff
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java changed 2.1% diff
streams/examples/src/main/java/org/apache/kafka/streams/examples/temperature/TemperatureDemo.java changed 7.2% diff
streams/src/main/java/org/apache/kafka/streams/internals/ApiUtils.java changed 69.5% diff
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java changed 16.1% diff
streams/src/main/java/org/apache/kafka/streams/KeyValue.java changed 1.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/Consumed.java changed 3.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java changed 21.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CacheFlushListener.java moved 18.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CacheFlushListener.java
streams/src/main/java/org/apache/kafka/streams/kstream/internals/Change.java changed 9.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java changed 7.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ForwardingCacheFlushListener.java changed 23.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GlobalKTableImpl.java changed 29.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableJoinNode.java changed 26.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.j
ava
changed 1.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSinkNode.java changed 1.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSourceNode.java changed 5.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamStreamJoinNode.java changed 11.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableProcessorNode.java changed 20.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java changed 45.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java changed 40.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java changed 15.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KeyValueStoreMaterializer.java changed 13.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java changed 10.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java changed 12.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java changed 5.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java changed 1.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java changed 4.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java changed 10.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransform.java renamed 43.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatTransform.java
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java changed 8.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowReduce.java removed
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java changed 5.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java changed 6.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java changed 13.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java changed 3.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java changed 9.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMapValues.java changed 3.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java changed 6.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java changed 48.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSourceValueGetterSupplier.ja
va
changed 3.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableTransformValues.java changed 2.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/MaterializedInternal.java changed 27.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/metrics/Sensors.java changed 61.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PrintedInternal.java changed 16.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SerializedInternal.java changed 15.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindow.java changed 4.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java changed 7.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/EagerBufferConfigImpl.jav
a
changed 10.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/FinalResultsSuppressionBu
ilder.java
changed 13.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessor.j
ava
changed 12.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/NamedSuppressed.java added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/StrictBufferConfigImpl.ja
va
changed 4.9% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/SuppressedInternal.java changed 49.1% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindow.java changed 3.8% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java changed 9.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TransformerSupplierAdapter.java added
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TupleForwarder.java changed 18.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/internals/UnlimitedWindow.java changed 4.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java changed 21.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KeyValueMapper.java changed 4.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java changed 11.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java changed 1.3% diff
streams/src/main/java/org/apache/kafka/streams/kstream/Materialized.java changed 3.2% diff
streams/src/main/java/org/apache/kafka/streams/kstream/Serialized.java changed 2.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java changed 15.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java changed 12.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java changed 1.5% diff
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedSerializer.java changed 5.0% diff
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java changed 17.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java changed 8.6% diff
streams/src/main/java/org/apache/kafka/streams/kstream/Window.java changed 3.4% diff
streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java changed 3.7% diff
streams/src/main/java/org/apache/kafka/streams/kstream/WindowedSerdes.java changed 42.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractStateManager.java changed 9.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java changed 3.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasks.java changed 69.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java changed 20.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java changed 5.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignor.ja
va
changed 10.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java changed 1.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java changed 8.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java changed 3.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java changed 0.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java changed 0.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java changed 1.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicConfig.java changed 3.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java changed 2.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java changed 3.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java changed 0.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java changed 19.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java changed 100.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java changed 1.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java changed 4.4% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java changed 18.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java changed 5.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/QuickUnion.java changed 6.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java changed 2.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java changed 19.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java changed 0.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java changed 8.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/RestoringTasks.java changed 0.3% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java changed 4.6% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/Stamped.java changed 19.9% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyContextImpl.java changed 3.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java changed 11.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java changed 7.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManager.java changed 5.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateRestorer.java changed 14.8% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java changed 2.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java changed 1.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java changed 7.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java changed 8.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java changed 2.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/TimestampSupplier.java removed
streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedChangelogTopicConfig.j
ava
changed 10.0% diff
streams/src/main/java/org/apache/kafka/streams/processor/internals/WindowedChangelogTopicConfig.jav
a
changed 17.7% diff
streams/src/main/java/org/apache/kafka/streams/processor/Processor.java changed 12.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java changed 1.1% diff
streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java changed 4.5% diff
streams/src/main/java/org/apache/kafka/streams/processor/ThreadMetadata.java changed 68.2% diff
streams/src/main/java/org/apache/kafka/streams/processor/To.java changed 1.9% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractSegments.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/CachedStateStore.java changed 5.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java changed 30.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java changed 33.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java changed 28.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStore.java changed 37.6% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java changed 24.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java changed 19.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStore.java changed 12.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java changed 24.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/ContextualRecord.java changed 9.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueLoggedStore.java removed
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java changed 2.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.ja
va
changed 9.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegment.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegments.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilder.java changed 0.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/LRUCacheEntry.java changed 5.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java changed 22.9% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheSessionStoreIterato
r.java
changed 3.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreKeyValue
Iterator.java
changed 4.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java changed 14.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java changed 27.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java changed 33.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/Sensors.java changed 89.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/QueryableStoreProvider.java changed 9.9% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RecordConverter.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/RecordConverters.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColu
mnFamilyOptionsAdapter.java
added
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbIterator.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbKeyValueBytesStoreSupplier.ja
va
changed 24.3% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBRangeIterator.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java changed 30.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStore.java changed 20.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java changed 55.0% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java changed 21.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java changed 59.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedBytesStore.java changed 3.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java changed 10.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/Segments.java changed 91.8% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionKeySchema.java changed 32.2% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreChangeLogger.java changed 16.5% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreProxyUtils.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedBytesStore.java added
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java changed 26.7% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreBuilder.java changed 22.1% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedStateStore.java changed 62.4% diff
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappingStoreProvider.java changed 10.8% diff
streams/src/main/java/org/apache/kafka/streams/state/KeyValueBytesStoreSupplier.java changed 22.0% diff
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java changed 7.4% diff
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreTypes.java changed 34.5% diff
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java changed 0.1% diff
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java changed 4.8% diff
streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java changed 13.3% diff
streams/src/main/java/org/apache/kafka/streams/state/Stores.java changed 5.8% diff
streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java changed 14.4% diff
streams/src/main/java/org/apache/kafka/streams/state/WindowBytesStoreSupplier.java changed 10.9% diff
streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java changed 22.8% diff
streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java changed 7.6% diff
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java changed 1.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java changed 11.1% diff
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java changed 1.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java changed 30.3% diff
streams/src/test/java/org/apache/kafka/streams/integration/FineGrainedAutoResetIntegrationTest.java changed 3.4% diff
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableEOSIntegrationTest.java changed 22.4% diff
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableIntegrationTest.java changed 24.0% diff
streams/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java changed 25.7% diff
streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationDedupIntegrationTest.j
ava
changed 2.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java changed 1.7% diff
streams/src/test/java/org/apache/kafka/streams/integration/KStreamTransformIntegrationTest.java added
streams/src/test/java/org/apache/kafka/streams/integration/KTableSourceTopicRestartIntegrationTest.
java
changed 9.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/PurgeRepartitionTopicIntegrationTest.jav
a
changed 27.0% diff
streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java changed 18.7% diff
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java changed 16.6% diff
streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java changed 18.7% diff
streams/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinIntegrationTest.java changed 1.3% diff
streams/src/test/java/org/apache/kafka/streams/integration/SuppressionDurabilityIntegrationTest.jav
a
changed 2.0% diff
streams/src/test/java/org/apache/kafka/streams/integration/SuppressionIntegrationTest.java changed 64.0% diff
streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java changed 2.4% diff
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java changed 24.4% diff
streams/src/test/java/org/apache/kafka/streams/integration/utils/KafkaEmbedded.java changed 8.0% diff
streams/src/test/java/org/apache/kafka/streams/internals/ApiUtilsTest.java added
streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java changed 53.1% diff
streams/src/test/java/org/apache/kafka/streams/KeyValueTest.java changed 1.5% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/AbstractStreamTest.java changed 11.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilderTest.java changed 11.2% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImplTest.java changed 36.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImplTest.java changed 47.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFlatTransformTest.java added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java changed 9.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java changed 4.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamPrintTest.java changed 41.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregateProce
ssorTest.java
changed 13.2% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamTransformTest.java changed 2.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValuesTest.java changed 0.5% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregateTest.java changed 0.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamWindowReduceTest.java removed
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableAggregateTest.java changed 3.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableFilterTest.java changed 30.3% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableImplTest.java changed 58.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoinTest.java changed 59.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoinTest.java changed 5.7% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoinTest.java changed 1.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoinTest.java changed 1.5% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableMapValuesTest.java changed 45.5% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableSourceTest.java changed 5.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableTransformValuesTest.java changed 5.6% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/MaterializedInternalTest.java changed 13.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImplTest.jav
a
changed 1.2% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorMe
tricsTest.java
added
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorTe
st.java
changed 7.7% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SuppressScenarioTest.java changed 7.4% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImplTest.java changed 32.8% diff
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TransformerSupplierAdapterTest.jav
a
added
streams/src/test/java/org/apache/kafka/streams/kstream/JoinWindowsTest.java changed 23.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/RepartitionTopicNamingTest.java changed 28.9% diff
streams/src/test/java/org/apache/kafka/streams/kstream/SessionWindowsTest.java changed 23.0% diff
streams/src/test/java/org/apache/kafka/streams/kstream/TimeWindowsTest.java changed 15.1% diff
streams/src/test/java/org/apache/kafka/streams/kstream/UnlimitedWindowsTest.java changed 1.0% diff
streams/src/test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java changed 0.6% diff
streams/src/test/java/org/apache/kafka/streams/perf/YahooBenchmark.java changed 22.2% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContextTest.jav
a
changed 1.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/AbstractTaskTest.java changed 2.3% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java changed 0.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignorTes
t.java
changed 0.4% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/CompositeRestoreListenerTest.jav
a
changed 1.8% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/CopartitionedTopicsValidatorTest
.java
changed 21.7% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImplTest.j
ava
added
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java changed 18.2% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateTaskTest.java changed 2.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStreamThreadTest.java changed 23.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java changed 1.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/KeyValueStoreMaterializerTest.ja
va
changed 23.0% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImplTest.j
ava
changed 3.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java added
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextTest.java added
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java changed 13.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java changed 20.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java changed 2.7% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/SinkNodeTest.java changed 14.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/SourceNodeTest.java changed 16.3% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java changed 8.3% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateConsumerTest.java changed 5.7% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java changed 30.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerStub.java changed 4.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateRestorerTest.java changed 14.3% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java changed 30.2% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsMetadataStateTest.java changed 0.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.jav
a
changed 14.5% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java changed 12.3% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java changed 22.6% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java changed 4.1% diff
streams/src/test/java/org/apache/kafka/streams/processor/internals/testutil/LogCaptureAppender.java changed 71.7% diff
streams/src/test/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestampTest.java changed 5.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractKeyValueStoreTest.java changed 7.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingKeyValueStoreTest.java changed 20.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingSessionStoreTest.java changed 18.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingWindowStoreTest.java changed 26.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStoreTest.
java
changed 1.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStoreTest.j
ava
changed 3.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStoreTest.ja
va
changed 1.4% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStoreTest.ja
va
changed 4.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStoreTest.jav
a
changed 1.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/FilteredCacheIteratorTest.java changed 3.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilderTest.java changed 11.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedSessionStore
IteratorTest.java
changed 28.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedWindowStoreK
eyValueIteratorTest.java
changed 21.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ReadOnlyWindowStoreStub.java changed 15.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColu
mnFamilyOptionsAdapterTest.java
added
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStoreTest.java changed 11.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBSessionStoreTest.java changed 21.9% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java changed 30.0% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStoreTest.java added
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreTest.java changed 60.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/SegmentIteratorTest.java renamed 29.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueSegmentIteratorTest.java
streams/src/test/java/org/apache/kafka/streams/state/internals/SegmentsTest.java renamed 26.7% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueSegmentsTest.java
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionKeySchemaTest.java changed 27.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionStoreBuilderTest.java changed 12.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/StoreChangeLoggerTest.java changed 13.6% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProviderTest.j
ava
changed 13.5% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/ThreadCacheTest.java changed 0.2% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowKeySchemaTest.java changed 17.8% diff
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowStoreBuilderTest.java changed 12.7% diff
streams/src/test/java/org/apache/kafka/streams/state/StateSerdesTest.java changed 0.8% diff
streams/src/test/java/org/apache/kafka/streams/state/StoresTest.java changed 4.6% diff
streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java changed 49.2% diff
streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java changed 3.2% diff
streams/src/test/java/org/apache/kafka/streams/tests/BrokerCompatibilityTest.java changed 2.1% diff
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java changed 41.6% diff
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java changed 13.0% diff
streams/src/test/java/org/apache/kafka/streams/tests/StreamsNamedRepartitionTest.java added
streams/src/test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java added
streams/src/test/java/org/apache/kafka/streams/tests/StreamsStandByReplicaTest.java changed 26.7% diff
streams/src/test/java/org/apache/kafka/streams/TopologyTest.java changed 4.6% diff
streams/src/test/java/org/apache/kafka/test/GlobalStateManagerStub.java changed 2.9% diff
streams/src/test/java/org/apache/kafka/test/InternalMockProcessorContext.java changed 3.3% diff
streams/src/test/java/org/apache/kafka/test/KTableValueGetterStub.java removed
streams/src/test/java/org/apache/kafka/test/MockAggregator.java changed 16.6% diff
streams/src/test/java/org/apache/kafka/test/MockInitializer.java changed 0.3% diff
streams/src/test/java/org/apache/kafka/test/MockInternalProcessorContext.java changed 8.3% diff
streams/src/test/java/org/apache/kafka/test/MockKeyValueStore.java changed 2.8% diff
streams/src/test/java/org/apache/kafka/test/MockProcessor.java changed 9.8% diff
streams/src/test/java/org/apache/kafka/test/NoOpProcessorContext.java changed 5.6% diff
streams/src/test/java/org/apache/kafka/test/ReadOnlySessionStoreStub.java changed 2.1% diff
streams/src/test/java/org/apache/kafka/test/StreamsTestUtils.java changed 3.6% diff
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java changed 4.2% diff
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java changed 2.1% diff
streams/test-utils/src/test/java/org/apache/kafka/streams/MockProcessorContextTest.java changed 1.6% diff
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java changed 3.1% diff
streams/upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.jav
a
added
tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java changed 13.1% diff
tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java changed 1.0% diff
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java changed 10.8% diff
tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java changed 3.2% diff
tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java changed 2.4% diff
tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java changed 2.4% diff
tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java changed 4.0% diff
tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java changed 83.8% diff
tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java changed 86.0% diff
tools/src/main/java/org/apache/kafka/trogdor/agent/AgentRestResource.java changed 4.7% diff
tools/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java changed 6.5% diff
tools/src/main/java/org/apache/kafka/trogdor/common/JsonUtil.java changed 84.4% diff
tools/src/main/java/org/apache/kafka/trogdor/common/StringExpander.java changed 3.0% diff
tools/src/main/java/org/apache/kafka/trogdor/common/StringFormatter.java added
tools/src/main/java/org/apache/kafka/trogdor/common/WorkerUtils.java changed 8.5% diff
tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java changed 15.5% diff
tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java changed 100.0% diff
tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorRestResource.java changed 44.1% diff
tools/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java changed 20.0% diff
tools/src/main/java/org/apache/kafka/trogdor/coordinator/TaskManager.java changed 12.6% diff
tools/src/main/java/org/apache/kafka/trogdor/rest/JsonRestServer.java changed 5.1% diff
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskDone.java changed 3.9% diff
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskPending.java changed 7.8% diff
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskRequest.java added
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskRunning.java changed 6.2% diff
tools/src/main/java/org/apache/kafka/trogdor/rest/TasksRequest.java changed 16.7% diff
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskState.java changed 22.0% diff
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskStateType.java added
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskStopping.java changed 6.2% diff
tools/src/main/java/org/apache/kafka/trogdor/rest/UptimeResponse.java added
tools/src/main/java/org/apache/kafka/trogdor/task/TaskSpec.java changed 4.1% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressSpec.java changed 7.2% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressWorker.java changed 4.0% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchSpec.java changed 100.0% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java changed 95.0% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/PartitionsSpec.java changed 19.8% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchSpec.java changed 29.2% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java changed 32.3% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java changed 4.0% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkloadSpec.java changed 5.8% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/TopicsSpec.java changed 8.4% diff
tools/src/main/java/org/apache/kafka/trogdor/workload/TransactionGenerator.java added
tools/src/main/java/org/apache/kafka/trogdor/workload/UniformTransactionsGenerator.java added
tools/src/test/java/org/apache/kafka/trogdor/agent/AgentTest.java changed 36.1% diff
tools/src/test/java/org/apache/kafka/trogdor/common/ExpectedTasks.java changed 36.8% diff
tools/src/test/java/org/apache/kafka/trogdor/common/JsonSerializationTest.java changed 9.7% diff
tools/src/test/java/org/apache/kafka/trogdor/common/JsonUtilTest.java added
tools/src/test/java/org/apache/kafka/trogdor/common/MiniTrogdorCluster.java changed 18.2% diff
tools/src/test/java/org/apache/kafka/trogdor/common/StringExpanderTest.java changed 25.4% diff
tools/src/test/java/org/apache/kafka/trogdor/common/StringFormatterTest.java added
tools/src/test/java/org/apache/kafka/trogdor/coordinator/CoordinatorClientTest.java added
tools/src/test/java/org/apache/kafka/trogdor/coordinator/CoordinatorTest.java changed 42.3% diff
tools/src/test/java/org/apache/kafka/trogdor/task/SampleTaskWorker.java changed 10.9% diff
tools/src/test/java/org/apache/kafka/trogdor/workload/ConsumeBenchSpecTest.java added
tools/src/test/java/org/apache/kafka/trogdor/workload/TopicsSpecTest.java changed 19.7% diff

Python Programs (27 of 126):

NameStatusDeltaVisual Diff
kafka-merge-pr.py changed 0.4% diff
release.py changed 8.8% diff
tests/kafkatest/__init__.py changed 32.9% diff
tests/kafkatest/sanity_checks/test_console_consumer.py changed 2.0% diff
tests/kafkatest/services/connect.py changed 5.8% diff
tests/kafkatest/services/console_consumer.py changed 8.9% diff
tests/kafkatest/services/delegation_tokens.py added
tests/kafkatest/services/kafka/config_property.py changed 2.5% diff
tests/kafkatest/services/kafka/kafka.py changed 1.7% diff
tests/kafkatest/services/streams.py changed 12.0% diff
tests/kafkatest/services/trogdor/consume_bench_workload.py added
tests/kafkatest/services/trogdor/produce_bench_workload.py changed 18.4% diff
tests/kafkatest/services/verifiable_producer.py changed 17.9% diff
tests/kafkatest/services/zookeeper.py changed 6.4% diff
tests/kafkatest/tests/core/consume_bench_test.py added
tests/kafkatest/tests/core/consumer_group_command_test.py changed 2.1% diff
tests/kafkatest/tests/core/delegation_token_test.py added
tests/kafkatest/tests/core/get_offset_shell_test.py changed 3.3% diff
tests/kafkatest/tests/core/produce_bench_test.py changed 60.5% diff
tests/kafkatest/tests/produce_consume_validate.py changed 1.9% diff
tests/kafkatest/tests/streams/base_streams_test.py changed 3.3% diff
tests/kafkatest/tests/streams/streams_broker_bounce_test.py changed 8.5% diff
tests/kafkatest/tests/streams/streams_named_repartition_topic_test.py added
tests/kafkatest/tests/streams/streams_optimized_test.py added
tests/kafkatest/tests/streams/streams_upgrade_test.py changed 30.1% diff
tests/kafkatest/tests/tools/log4j_appender_test.py changed 2.2% diff
tests/kafkatest/version.py changed 4.9% diff

Shell Programs (6 of 46):

NameStatusDeltaVisual Diff
bin/kafka-run-class.sh changed 0.3% diff
tests/bin/trogdor-run-consume-bench.sh removed
tests/bin/trogdor-run-produce-bench.sh removed
tests/bin/trogdor-run-round-trip.sh removed
tests/docker/ducker-ak changed 2.3% diff
vagrant/base.sh changed 2.2% diff

Configuration Files (1 of 7):

NameStatusDeltaVisual Diff
tests/kafkatest/services/security/templates/jaas.conf changed 6.4% diff

JavaScript Files (all 1):

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

JSON Files (all 94):

NameStatusDeltaVisual Diff
clients/src/main/resources/common/message/AddOffsetsToTxnRequest.json added
clients/src/main/resources/common/message/AddOffsetsToTxnResponse.json added
clients/src/main/resources/common/message/AddPartitionsToTxnRequest.json added
clients/src/main/resources/common/message/AddPartitionsToTxnResponse.json added
clients/src/main/resources/common/message/AlterConfigsRequest.json added
clients/src/main/resources/common/message/AlterConfigsResponse.json added
clients/src/main/resources/common/message/AlterReplicaLogDirsRequest.json added
clients/src/main/resources/common/message/AlterReplicaLogDirsResponse.json added
clients/src/main/resources/common/message/ApiVersionsRequest.json added
clients/src/main/resources/common/message/ApiVersionsResponse.json added
clients/src/main/resources/common/message/ControlledShutdownRequest.json added
clients/src/main/resources/common/message/ControlledShutdownResponse.json added
clients/src/main/resources/common/message/CreateAclsRequest.json added
clients/src/main/resources/common/message/CreateAclsResponse.json added
clients/src/main/resources/common/message/CreateDelegationTokenRequest.json added
clients/src/main/resources/common/message/CreateDelegationTokenResponse.json added
clients/src/main/resources/common/message/CreatePartitionsRequest.json added
clients/src/main/resources/common/message/CreatePartitionsResponse.json added
clients/src/main/resources/common/message/CreateTopicsRequest.json added
clients/src/main/resources/common/message/CreateTopicsResponse.json added
clients/src/main/resources/common/message/DeleteAclsRequest.json added
clients/src/main/resources/common/message/DeleteAclsResponse.json added
clients/src/main/resources/common/message/DeleteGroupsRequest.json added
clients/src/main/resources/common/message/DeleteGroupsResponse.json added
clients/src/main/resources/common/message/DeleteRecordsRequest.json added
clients/src/main/resources/common/message/DeleteRecordsResponse.json added
clients/src/main/resources/common/message/DeleteTopicsRequest.json added
clients/src/main/resources/common/message/DeleteTopicsResponse.json added
clients/src/main/resources/common/message/DescribeAclsRequest.json added
clients/src/main/resources/common/message/DescribeAclsResponse.json added
clients/src/main/resources/common/message/DescribeConfigsRequest.json added
clients/src/main/resources/common/message/DescribeConfigsResponse.json added
clients/src/main/resources/common/message/DescribeDelegationTokenRequest.json added
clients/src/main/resources/common/message/DescribeDelegationTokenResponse.json added
clients/src/main/resources/common/message/DescribeGroupsRequest.json added
clients/src/main/resources/common/message/DescribeGroupsResponse.json added
clients/src/main/resources/common/message/DescribeLogDirsRequest.json added
clients/src/main/resources/common/message/DescribeLogDirsResponse.json added
clients/src/main/resources/common/message/ElectPreferredLeadersRequest.json added
clients/src/main/resources/common/message/ElectPreferredLeadersResponse.json added
clients/src/main/resources/common/message/EndTxnRequest.json added
clients/src/main/resources/common/message/EndTxnResponse.json added
clients/src/main/resources/common/message/ExpireDelegationTokenRequest.json added
clients/src/main/resources/common/message/ExpireDelegationTokenResponse.json added
clients/src/main/resources/common/message/FetchRequest.json added
clients/src/main/resources/common/message/FetchResponse.json added
clients/src/main/resources/common/message/FindCoordinatorRequest.json added
clients/src/main/resources/common/message/FindCoordinatorResponse.json added
clients/src/main/resources/common/message/HeartbeatRequest.json added
clients/src/main/resources/common/message/HeartbeatResponse.json added
clients/src/main/resources/common/message/InitProducerIdRequest.json added
clients/src/main/resources/common/message/InitProducerIdResponse.json added
clients/src/main/resources/common/message/JoinGroupRequest.json added
clients/src/main/resources/common/message/JoinGroupResponse.json added
clients/src/main/resources/common/message/LeaderAndIsrRequest.json added
clients/src/main/resources/common/message/LeaderAndIsrResponse.json added
clients/src/main/resources/common/message/LeaveGroupRequest.json added
clients/src/main/resources/common/message/LeaveGroupResponse.json added
clients/src/main/resources/common/message/ListGroupsRequest.json added
clients/src/main/resources/common/message/ListGroupsResponse.json added
clients/src/main/resources/common/message/ListOffsetRequest.json added
clients/src/main/resources/common/message/ListOffsetResponse.json added
clients/src/main/resources/common/message/MetadataRequest.json added
clients/src/main/resources/common/message/MetadataResponse.json added
clients/src/main/resources/common/message/OffsetCommitRequest.json added
clients/src/main/resources/common/message/OffsetCommitResponse.json added
clients/src/main/resources/common/message/OffsetFetchRequest.json added
clients/src/main/resources/common/message/OffsetFetchResponse.json added
clients/src/main/resources/common/message/OffsetForLeaderEpochRequest.json added
clients/src/main/resources/common/message/OffsetForLeaderEpochResponse.json added
clients/src/main/resources/common/message/ProduceRequest.json added
clients/src/main/resources/common/message/ProduceResponse.json added
clients/src/main/resources/common/message/RenewDelegationTokenRequest.json added
clients/src/main/resources/common/message/RenewDelegationTokenResponse.json added
clients/src/main/resources/common/message/RequestHeader.json added
clients/src/main/resources/common/message/ResponseHeader.json added
clients/src/main/resources/common/message/SaslAuthenticateRequest.json added
clients/src/main/resources/common/message/SaslAuthenticateResponse.json added
clients/src/main/resources/common/message/SaslHandshakeRequest.json added
clients/src/main/resources/common/message/SaslHandshakeResponse.json added
clients/src/main/resources/common/message/StopReplicaRequest.json added
clients/src/main/resources/common/message/StopReplicaResponse.json added
clients/src/main/resources/common/message/SyncGroupRequest.json added
clients/src/main/resources/common/message/SyncGroupResponse.json added
clients/src/main/resources/common/message/TxnOffsetCommitRequest.json added
clients/src/main/resources/common/message/TxnOffsetCommitResponse.json added
clients/src/main/resources/common/message/UpdateMetadataRequest.json added
clients/src/main/resources/common/message/UpdateMetadataResponse.json added
clients/src/main/resources/common/message/WriteTxnMarkersRequest.json added
clients/src/main/resources/common/message/WriteTxnMarkersResponse.json added
tests/spec/round_trip.json added
tests/spec/simple_consume_bench_spec.json added
tests/spec/simple_produce_bench.json added
tests/spec/transactional-produce-bench.json added

XML Documents (7 of 9):

NameStatusDeltaVisual Diff
checkstyle/import-control-core.xml changed 8.7% diff
checkstyle/import-control.xml changed 4.0% diff
checkstyle/suppressions.xml changed 11.9% diff
gradle/spotbugs-exclude.xml changed 1.4% 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 23):

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

Git Files (2 of 8):

NameStatusDeltaVisual Diff
.gitignore changed 4.4% diff
tests/.gitignore changed 21.5% diff

HTML Pages (17 of 58):

NameStatusDeltaVisual Diff
docs/api.html changed 0.4%
docs/configuration.html changed 0.1%
docs/design.html changed 0.01%
docs/documentation.html changed 1.0%
docs/ops.html changed 4.7%
docs/quickstart.html changed 0.6%
docs/security.html changed 19.1%
docs/streams/developer-guide/app-reset-tool.html changed 0.01%
docs/streams/developer-guide/config-streams.html changed 0.001%
docs/streams/developer-guide/dsl-api.html changed 0.1%
docs/streams/developer-guide/interactive-queries.html changed 0.001%
docs/streams/developer-guide/processor-api.html changed 0.002%
docs/streams/developer-guide/write-streams.html changed 0.1%
docs/streams/quickstart.html changed 0.1%
docs/streams/upgrade-guide.html changed 3.3%
docs/toc.html changed 8.1%
docs/upgrade.html changed 1.3%

Property Files (1 of 41):

NameStatusDeltaVisual Diff
gradle.properties changed 11.2% diff

Directories (29 of 668):

NameStatus
clients/src/main/resources/common added
clients/src/main/resources/common/message added
clients/src/test/java/org/apache/kafka/common/message added
generator added
generator/src added
generator/src/main added
generator/src/main/java added
generator/src/main/java/org added
generator/src/main/java/org/apache added
generator/src/main/java/org/apache/kafka added
generator/src/main/java/org/apache/kafka/message added
generator/src/test added
generator/src/test/java added
generator/src/test/java/org added
generator/src/test/java/org/apache added
generator/src/test/java/org/apache/kafka added
generator/src/test/java/org/apache/kafka/message added
streams/src/test/java/org/apache/kafka/streams/internals added
streams/upgrade-system-tests-21 added
streams/upgrade-system-tests-21/src added
streams/upgrade-system-tests-21/src/test added
streams/upgrade-system-tests-21/src/test/java added
streams/upgrade-system-tests-21/src/test/java/org added
streams/upgrade-system-tests-21/src/test/java/org/apache added
streams/upgrade-system-tests-21/src/test/java/org/apache/kafka added
streams/upgrade-system-tests-21/src/test/java/org/apache/kafka/streams added
streams/upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests added
tests/bin removed
tests/spec added

Readme Files (2 of 6):

NameStatusDeltaVisual Diff
clients/src/main/resources/common/message/README.md added
README.md changed 14.1% diff

Text Files (141 of 414):

NameStatusDeltaVisual Diff
build.gradle changed 5.0% diff
core/src/main/scala/kafka/admin/AdminClient.scala changed 1.7% diff
core/src/main/scala/kafka/admin/AdminUtils.scala changed 2.4% diff
core/src/main/scala/kafka/api/ApiVersion.scala changed 7.2% diff
core/src/main/scala/kafka/cluster/Partition.scala changed 7.8% diff
core/src/main/scala/kafka/cluster/Replica.scala changed 5.6% diff
core/src/main/scala/kafka/controller/ControllerChannelManager.scala changed 20.0% diff
core/src/main/scala/kafka/controller/ControllerEventManager.scala changed 5.5% diff
core/src/main/scala/kafka/controller/KafkaController.scala changed 14.8% diff
core/src/main/scala/kafka/controller/PartitionStateMachine.scala changed 6.3% diff
core/src/main/scala/kafka/coordinator/group/DelayedHeartbeat.scala changed 21.0% diff
core/src/main/scala/kafka/coordinator/group/DelayedJoin.scala changed 0.7% diff
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala changed 26.3% diff
core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala changed 4.9% diff
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala changed 0.7% diff
core/src/main/scala/kafka/coordinator/group/MemberMetadata.scala changed 4.4% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala changed 0.2% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala changed 0.1% diff
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala changed 0.7% diff
core/src/main/scala/kafka/log/AbstractIndex.scala changed 3.3% diff
core/src/main/scala/kafka/log/Log.scala changed 2.0% diff
core/src/main/scala/kafka/log/LogCleaner.scala changed 1.0% diff
core/src/main/scala/kafka/log/LogCleanerManager.scala changed 0.7% diff
core/src/main/scala/kafka/log/LogManager.scala changed 8.0% diff
core/src/main/scala/kafka/log/LogSegment.scala changed 1.3% diff
core/src/main/scala/kafka/log/LogValidator.scala changed 5.7% diff
core/src/main/scala/kafka/log/OffsetIndex.scala changed 0.6% diff
core/src/main/scala/kafka/network/SocketServer.scala changed 45.2% diff
core/src/main/scala/kafka/server/AbstractFetcherManager.scala changed 0.7% diff
core/src/main/scala/kafka/server/AbstractFetcherThread.scala changed 3.8% diff
core/src/main/scala/kafka/server/AdminManager.scala changed 1.9% diff
core/src/main/scala/kafka/server/DelayedElectPreferredLeader.scala added
core/src/main/scala/kafka/server/DelayedOperation.scala changed 9.7% diff
core/src/main/scala/kafka/server/DelegationTokenManager.scala changed 4.7% diff
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala changed 0.2% diff
core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala changed 1.6% diff
core/src/main/scala/kafka/server/KafkaApis.scala changed 6.2% diff
core/src/main/scala/kafka/server/KafkaConfig.scala changed 5.5% diff
core/src/main/scala/kafka/server/KafkaRequestHandler.scala changed 5.7% diff
core/src/main/scala/kafka/server/KafkaServer.scala changed 8.3% diff
core/src/main/scala/kafka/server/MetadataCache.scala changed 13.4% diff
core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala changed 3.2% diff
core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala changed 0.3% diff
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala changed 3.8% diff
core/src/main/scala/kafka/server/ReplicaManager.scala changed 3.9% diff
core/src/main/scala/kafka/server/ThrottledChannel.scala changed 2.7% diff
core/src/main/scala/kafka/tools/PerfConfig.scala changed 9.4% diff
core/src/main/scala/kafka/utils/CommandDefaultOptions.scala added
core/src/main/scala/kafka/utils/CommandLineUtils.scala changed 95.5% diff
core/src/main/scala/kafka/utils/CoreUtils.scala changed 0.4% diff
core/src/main/scala/kafka/utils/FileLock.scala changed 7.4% diff
core/src/main/scala/kafka/utils/IteratorTemplate.scala removed
core/src/main/scala/kafka/utils/json/DecodeJson.scala changed 6.9% diff
core/src/main/scala/kafka/utils/json/JsonObject.scala changed 6.2% diff
core/src/main/scala/kafka/utils/json/JsonValue.scala changed 5.7% diff
core/src/main/scala/kafka/utils/KafkaScheduler.scala changed 1.8% diff
core/src/main/scala/kafka/utils/Mx4jLoader.scala changed 8.2% diff
core/src/main/scala/kafka/utils/ZkUtils.scala changed 1.0% diff
core/src/main/scala/kafka/zk/AdminZkClient.scala changed 13.9% diff
core/src/main/scala/kafka/zk/KafkaZkClient.scala changed 23.2% diff
core/src/main/scala/kafka/zk/ZkData.scala changed 0.8% diff
core/src/main/scala/kafka/zk/ZkSecurityMigratorUtils.scala added
core/src/main/scala/kafka/zookeeper/ZooKeeperClient.scala changed 24.4% diff
core/src/test/scala/integration/kafka/admin/ReassignPartitionsIntegrationTest.scala changed 5.7% diff
core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala changed 15.6% diff
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala changed 3.8% diff
core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala changed 21.7% diff
core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala changed 3.1% diff
core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala changed 1.2% diff
core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala changed 55.2% diff
core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala changed 1.5% diff
core/src/test/scala/integration/kafka/api/DelegationTokenEndToEndAuthorizationTest.scala changed 13.1% diff
core/src/test/scala/integration/kafka/api/EndToEndClusterIdTest.scala changed 4.7% diff
core/src/test/scala/integration/kafka/api/GroupCoordinatorIntegrationTest.scala changed 2.6% diff
core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala changed 3.7% diff
core/src/test/scala/integration/kafka/api/LegacyAdminClientTest.scala changed 2.4% diff
core/src/test/scala/integration/kafka/api/LogAppendTimeTest.scala changed 14.0% diff
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala changed 14.0% diff
core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala changed 2.8% diff
core/src/test/scala/integration/kafka/api/SaslEndToEndAuthorizationTest.scala changed 1.0% diff
core/src/test/scala/integration/kafka/api/SaslMultiMechanismConsumerTest.scala changed 9.1% diff
core/src/test/scala/integration/kafka/api/SaslPlainPlaintextConsumerTest.scala changed 16.9% diff
core/src/test/scala/integration/kafka/api/SaslPlainSslEndToEndAuthorizationTest.scala changed 4.9% diff
core/src/test/scala/integration/kafka/api/SaslSslAdminClientIntegrationTest.scala changed 0.7% diff
core/src/test/scala/integration/kafka/api/TransactionsTest.scala changed 0.3% diff
core/src/test/scala/integration/kafka/server/DelayedFetchTest.scala changed 1.5% diff
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala changed 1.5% diff
core/src/test/scala/integration/kafka/server/GssapiAuthenticationTest.scala changed 1.3% diff
core/src/test/scala/integration/kafka/server/MultipleListenersWithSameSecurityProtocolBaseTest.scal
a
changed 5.4% diff
core/src/test/scala/integration/kafka/tools/MirrorMakerIntegrationTest.scala changed 4.9% diff
core/src/test/scala/kafka/tools/CustomDeserializerTest.scala added
core/src/test/scala/unit/kafka/admin/AdminTest.scala changed 3.8% diff
core/src/test/scala/unit/kafka/admin/DeleteConsumerGroupsTest.scala changed 13.5% diff
core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala changed 0.6% diff
core/src/test/scala/unit/kafka/admin/PreferredReplicaElectionCommandTest.scala changed 4.2% diff
core/src/test/scala/unit/kafka/admin/PreferredReplicaLeaderElectionCommandTest.scala added
core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala changed 1.2% diff
core/src/test/scala/unit/kafka/admin/ReassignPartitionsCommandArgsTest.scala changed 10.0% diff
core/src/test/scala/unit/kafka/admin/ReassignPartitionsCommandTest.scala changed 0.4% diff
core/src/test/scala/unit/kafka/admin/TestAdminUtils.scala changed 7.7% diff
core/src/test/scala/unit/kafka/admin/TopicCommandTest.scala changed 100.0% diff
core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala added
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala changed 36.1% diff
core/src/test/scala/unit/kafka/controller/PartitionStateMachineTest.scala changed 3.9% diff
core/src/test/scala/unit/kafka/coordinator/AbstractCoordinatorConcurrencyTest.scala changed 1.2% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorConcurrencyTest.scala changed 1.0% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorTest.scala changed 17.0% diff
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataTest.scala changed 3.8% diff
core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala changed 0.8% diff
core/src/test/scala/unit/kafka/network/SocketServerTest.scala changed 20.9% diff
core/src/test/scala/unit/kafka/security/auth/ZkAuthorizationTest.scala changed 52.6% diff
core/src/test/scala/unit/kafka/security/token/delegation/DelegationTokenManagerTest.scala changed 7.6% diff
core/src/test/scala/unit/kafka/server/AbstractCreateTopicsRequestTest.scala changed 1.8% diff
core/src/test/scala/unit/kafka/server/BrokerEpochIntegrationTest.scala added
core/src/test/scala/unit/kafka/server/DynamicConfigChangeTest.scala changed 1.0% diff
core/src/test/scala/unit/kafka/server/epoch/EpochDrivenReplicationProtocolAcceptanceTest.scala changed 5.1% diff
core/src/test/scala/unit/kafka/server/epoch/LeaderEpochIntegrationTest.scala changed 0.8% diff
core/src/test/scala/unit/kafka/server/epoch/util/ReplicaFetcherMockBlockingSend.scala changed 10.2% diff
core/src/test/scala/unit/kafka/server/LeaderElectionTest.scala changed 6.5% diff
core/src/test/scala/unit/kafka/server/ListOffsetsRequestTest.scala changed 32.9% diff
core/src/test/scala/unit/kafka/server/LogDirFailureTest.scala changed 3.9% diff
core/src/test/scala/unit/kafka/server/LogOffsetTest.scala changed 1.9% diff
core/src/test/scala/unit/kafka/server/MetadataRequestTest.scala changed 1.8% diff
core/src/test/scala/unit/kafka/server/ReplicationQuotasTest.scala changed 0.5% diff
core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala changed 7.8% diff
core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala changed 2.9% diff
core/src/test/scala/unit/kafka/server/StopReplicaRequestTest.scala changed 9.5% diff
core/src/test/scala/unit/kafka/utils/IteratorTemplateTest.scala removed
core/src/test/scala/unit/kafka/utils/TestUtils.scala changed 8.1% diff
core/src/test/scala/unit/kafka/utils/ZkUtilsTest.scala changed 1.6% diff
core/src/test/scala/unit/kafka/zk/AdminZkClientTest.scala changed 7.0% diff
core/src/test/scala/unit/kafka/zk/EmbeddedZookeeper.scala changed 7.5% diff
core/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala changed 9.7% diff
core/src/test/scala/unit/kafka/zk/ZooKeeperTestHarness.scala changed 3.4% diff
core/src/test/scala/unit/kafka/zookeeper/ZooKeeperClientTest.scala changed 0.4% diff
gradle/dependencies.gradle changed 8.3% diff
gradle/rat.gradle changed 1.4% diff
settings.gradle changed 16.4% diff
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KGroupedTable.scala changed 1.8% diff
tests/docker/Dockerfile changed 10.5% diff
TROGDOR.md changed 44.7% diff

Packages Compared:

kafka-2.1.1-src.tgz
kafka-2.2.0-src.tgz


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