"Fossies" - the Fresh Open Source Software Archive  

Source code changes report for "apache-pulsar" between the packages
apache-pulsar-2.5.2-src.tar.gz and apache-pulsar-2.6.0-src.tar.gz

About: Apache Pulsar is a distributed pub-sub messaging system.

Summary:

The "apache-pulsar" source code changed by about 10.8% and now consists of 3566 regular files (+215), 1 symbolic link and 2031 directories (+149).

Related Informations:

None found by Fossies.

Changes In Files (According File Type):

File TypeTotalAddedRemovedChanged
Header file 141 3 0 26
C program 9 0 0 0
C++ program 142 3 0 29
Spec file 1 0 0 0
Go program 65 13 6 17
Java program 2462 183 26 691
Python program 60 0 0 6
Shell program 75 17 0 12
Ruby program 1 0 0 0
CMake file 7 0 0 3
Configuration file 42 0 0 7
Initialization file 4 0 0 0
JavaScript file 1 0 0 0
JSON file 14 0 0 5
Man page 5 0 0 0
SGML document 6 5 0 0
Symbolic link 1 0 0 0
XML document 190 12 1 129
Certificate file 74 0 0 0
Command file 1 0 0 0
CSS style sheet 1 0 0 0
Doxygen file 1 0 0 0
HTML page 13 0 0 0
Property file 10 0 0 3
Protocol Buffer file 11 0 0 3
Service file 4 0 0 0
YAML file 183 38 35 52
Directory 2056 174 25 0
Archive 5 0 0 1
Information file 2 1 0 0
License 36 0 1 2
Readme file 19 1 1 2
Text file 51 9 0 8
Total Files569345995996



Header Files (29 of 141):

NameStatusDeltaVisual Diff
pulsar-client-cpp/include/pulsar/c/consumer_configuration.h changed 18.0% diff
pulsar-client-cpp/include/pulsar/c/producer_configuration.h changed 1.3% diff
pulsar-client-cpp/include/pulsar/ClientConfiguration.h changed 6.0% diff
pulsar-client-cpp/include/pulsar/ConsumerConfiguration.h changed 12.6% diff
pulsar-client-cpp/include/pulsar/Logger.h changed 4.1% diff
pulsar-client-cpp/include/pulsar/Result.h changed 0.6% diff
pulsar-client-cpp/lib/AckGroupingTracker.h added
pulsar-client-cpp/lib/AckGroupingTrackerDisabled.h added
pulsar-client-cpp/lib/AckGroupingTrackerEnabled.h added
pulsar-client-cpp/lib/BatchMessageContainer.h changed 11.4% diff
pulsar-client-cpp/lib/BlockingQueue.h changed 0.7% diff
pulsar-client-cpp/lib/ClientConfigurationImpl.h changed 7.0% diff
pulsar-client-cpp/lib/ClientConnection.h changed 0.9% diff
pulsar-client-cpp/lib/ClientImpl.h changed 1.0% diff
pulsar-client-cpp/lib/Commands.h changed 10.0% diff
pulsar-client-cpp/lib/ConsumerConfigurationImpl.h changed 5.3% diff
pulsar-client-cpp/lib/ConsumerImpl.h changed 11.9% diff
pulsar-client-cpp/lib/ConsumerImplBase.h changed 4.5% diff
pulsar-client-cpp/lib/LogUtils.h changed 2.8% diff
pulsar-client-cpp/lib/MultiTopicsConsumerImpl.h changed 1.3% diff
pulsar-client-cpp/lib/NegativeAcksTracker.h changed 6.7% diff
pulsar-client-cpp/lib/PartitionedConsumerImpl.h changed 1.2% diff
pulsar-client-cpp/lib/ProducerImpl.h changed 3.3% diff
pulsar-client-cpp/lib/SimpleLoggerImpl.h changed 5.2% diff
pulsar-client-cpp/lib/stats/ConsumerStatsImpl.h changed 3.6% diff
pulsar-client-cpp/lib/stats/ProducerStatsImpl.h changed 2.9% diff
pulsar-client-cpp/lib/TopicName.h changed 8.6% diff
pulsar-client-cpp/perf/RateLimiter.h changed 1.5% diff
pulsar-client-cpp/tests/PulsarFriend.h changed 38.0% diff

C++ Programs (32 of 142):

NameStatusDeltaVisual Diff
pulsar-client-cpp/lib/AckGroupingTracker.cc added
pulsar-client-cpp/lib/AckGroupingTrackerDisabled.cc added
pulsar-client-cpp/lib/AckGroupingTrackerEnabled.cc added
pulsar-client-cpp/lib/BatchMessageContainer.cc changed 26.0% diff
pulsar-client-cpp/lib/c/c_ClientConfiguration.cc changed 1.6% diff
pulsar-client-cpp/lib/c/c_ConsumerConfiguration.cc changed 13.4% diff
pulsar-client-cpp/lib/checksum/crc32c_sse42.cc changed 5.2% diff
pulsar-client-cpp/lib/ClientConfiguration.cc changed 4.7% diff
pulsar-client-cpp/lib/ClientConnection.cc changed 2.2% diff
pulsar-client-cpp/lib/ClientImpl.cc changed 4.2% diff
pulsar-client-cpp/lib/Commands.cc changed 7.3% diff
pulsar-client-cpp/lib/ConsumerConfiguration.cc changed 7.4% diff
pulsar-client-cpp/lib/ConsumerImpl.cc changed 6.4% diff
pulsar-client-cpp/lib/LogUtils.cc changed 35.3% diff
pulsar-client-cpp/lib/MultiTopicsConsumerImpl.cc changed 1.0% diff
pulsar-client-cpp/lib/NegativeAcksTracker.cc changed 12.7% diff
pulsar-client-cpp/lib/PartitionedConsumerImpl.cc changed 2.2% diff
pulsar-client-cpp/lib/ProducerImpl.cc changed 7.7% diff
pulsar-client-cpp/lib/Result.cc changed 1.8% diff
pulsar-client-cpp/lib/SimpleLoggerImpl.cc changed 10.8% diff
pulsar-client-cpp/lib/stats/ConsumerStatsImpl.cc changed 4.0% diff
pulsar-client-cpp/lib/stats/ProducerStatsImpl.cc changed 3.2% diff
pulsar-client-cpp/lib/TopicName.cc changed 7.7% diff
pulsar-client-cpp/perf/PerfProducer.cc changed 0.3% diff
pulsar-client-cpp/python/src/message.cc changed 15.1% diff
pulsar-client-cpp/tests/BackoffTest.cc changed 1.3% diff
pulsar-client-cpp/tests/BasicEndToEndTest.cc changed 20.5% diff
pulsar-client-cpp/tests/BatchMessageTest.cc changed 1.1% diff
pulsar-client-cpp/tests/ConsumerConfigurationTest.cc changed 7.3% diff
pulsar-client-cpp/tests/ConsumerTest.cc changed 2.5% diff
pulsar-client-cpp/tests/LatchTest.cc changed 16.6% diff
pulsar-client-cpp/tests/MessageTest.cc changed 3.2% diff

Go Programs (36 of 65):

NameStatusDeltaVisual Diff
pulsar-client-go/pulsar/c_message.go changed 4.1% diff
pulsar-client-go/pulsar/message.go changed 2.7% diff
pulsar-client-go/pulsar/producer_test.go changed 17.0% diff
pulsar-function-go/conf/conf.go changed 14.3% diff
pulsar-function-go/examples/contextFunc.go moved 0.0%
pulsar-function-go/examples/contextFunc/contextFunc.go
pulsar-function-go/examples/exclamationFunc/exclamationFunc.go added
pulsar-function-go/examples/hello.go moved 0.0%
pulsar-function-go/examples/hello/hello.go
pulsar-function-go/examples/inputFunc.go moved 5.8% diff
pulsar-function-go/examples/inputFunc/inputFunc.go
pulsar-function-go/examples/logFunc/logFunc.go added
pulsar-function-go/examples/outputFunc.go moved 0.0%
pulsar-function-go/examples/outputFunc/outputFunc.go
pulsar-function-go/examples/test/consumer.go moved 3.5% diff
pulsar-function-go/examples/consumer/consumer.go
pulsar-function-go/examples/test/producer.go moved 12.8% diff
pulsar-function-go/examples/producer/producer.go
pulsar-function-go/pb/doc.go changed 0.9% diff
pulsar-function-go/pb/Function.pb.go changed 53.2% diff
pulsar-function-go/pb/InstanceCommunication.pb.go changed 38.2% diff
pulsar-function-go/pb/Request.pb.go changed 11.0% diff
pulsar-function-go/pf/context.go changed 37.0% diff
pulsar-function-go/pf/context_test.go changed 16.0% diff
pulsar-function-go/pf/function.go changed 4.5% diff
pulsar-function-go/pf/function_test.go changed 4.2% diff
pulsar-function-go/pf/instance.go changed 100.0% diff
pulsar-function-go/pf/instance_test.go added
pulsar-function-go/pf/instanceConf.go changed 27.5% diff
pulsar-function-go/pf/instanceControlServicer.go added
pulsar-function-go/pf/instanceControlServicer_test.go added
pulsar-function-go/pf/logAppender.go changed 13.8% diff
pulsar-function-go/pf/stats.go added
pulsar-function-go/pf/stats_test.go added
pulsar-function-go/pf/util.go changed 16.5% diff
pulsar-function-go/pf/util_test.go changed 5.2% diff

Java Programs (900 of 2462):

NameStatusDeltaVisual Diff
examples/flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/example/PulsarConsumerSou
rceWordCount.java
changed 3.1% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/AsyncCallbacks.java changed 5.3% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryCacheManager.java changed 1.9% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryImpl.java changed 1.2% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorContainer.java changed 25.9% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java changed 12.9% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryImpl.java changed 28.9% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryMBeanImpl.java changed 1.6% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java changed 5.7% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java changed 1.9% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerOfflineBacklog.java changed 2.5% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/MetaStore.java changed 9.2% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/MetaStoreImplZookeeper.java renamed 84.1% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/MetaStoreImpl.java
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorImpl.java changed 8.0% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java changed 1.6% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java changed 6.2% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/PositionImpl.java changed 14.9% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/PositionImplRecyclable.java changed 4.7% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ReadOnlyCursorImpl.java changed 10.6% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ReadOnlyManagedLedgerImpl.java changed 8.1% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/LedgerOffloaderFactory.java changed 1.1% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedCursor.java changed 7.8% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedger.java changed 10.5% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerConfig.java changed 6.1% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerException.java changed 7.3% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerFactory.java changed 21.3% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerFactoryConfig.java changed 18.4% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerInfo.java changed 5.4% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/offload/OffloaderUtils.java changed 14.4% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/offload/OffloadUtils.java changed 1.6% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/RangeCache.java changed 1.1% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/Rate.java moved 1.9% diff
pulsar-common/src/main/java/org/apache/pulsar/common/stats/Rate.java
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/EntryCacheManagerTest.java changed 2.6% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/EntryCacheTest.java changed 3.5% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedCursorContainerTest.java changed 5.3% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedCursorTest.java changed 7.2% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerErrorsTest.java changed 13.7% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java changed 9.9% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/MetaStoreImplZookeeperTest.java renamed 38.0% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/MetaStoreImplTest.java
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorTest.java changed 4.8% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/util/RangeCacheTest.java changed 2.7% diff
managed-ledger/src/test/java/org/apache/bookkeeper/test/BookKeeperClusterTestCase.java changed 0.7% diff
pulsar-broker-auth-sasl/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProvide
rSasl.java
changed 1.0% diff
pulsar-broker-auth-sasl/src/main/java/org/apache/pulsar/broker/authentication/PulsarSaslServer.java changed 2.2% diff
pulsar-broker-auth-sasl/src/main/java/org/apache/pulsar/broker/authentication/SaslRoleTokenSigner.j
ava
changed 2.0% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationDataComman
d.java
changed 40.1% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationDataSource
.java
changed 18.5% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderTo
ken.java
changed 33.6% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationService.ja
va
changed 8.4% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/utils/AuthTokenUtils.jav
a
changed 24.3% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationProvider.jav
a
changed 100.0% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java changed 73.1% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvid
er.java
changed 29.9% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/cache/ConfigurationCacheService.java changed 2.7% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java changed 14.7% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/validator/MultipleListenerValidator.jav
a
added
pulsar-broker-common/src/main/java/org/apache/pulsar/common/configuration/PulsarConfigurationLoader
.java
changed 3.5% diff
pulsar-broker-common/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProviderTo
kenTest.java
changed 43.1% diff
pulsar-broker-common/src/test/java/org/apache/pulsar/broker/validator/MultipleListenerValidatorTest
.java
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java changed 4.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java changed 2.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokerStatsBase.java changed 0.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/ClustersBase.java changed 0.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/FunctionsBase.java changed 1.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java changed 23.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java changed 19.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinksBase.java changed 5.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourcesBase.java changed 5.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TenantsBase.java changed 6.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Functions.java changed 4.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java changed 16.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/NonPersistentTopics.java changed 10.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java changed 29.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/ResourceQuotas.java changed 16.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Functions.java changed 2.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java changed 23.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/NonPersistentTopics.java changed 3.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java changed 14.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/ResourceQuotas.java changed 49.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/SchemasResource.java changed 0.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactory.java changed 24.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java changed 12.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptor.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptorDefinition.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptorDefinitions.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptorMetadata.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptors.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptorUtils.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptorWithClassLoader.jav
a
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/package-info.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/GenericBrokerHostUsageImpl.ja
va
changed 2.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java changed 8.1% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LoadManagerShared.java changed 0.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java changed 11.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerWrapper.jav
a
changed 7.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/OverloadShedder.java changed 2.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/PulsarLoadReportImpl.java changed 2.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/SimpleLoadManagerImpl.java changed 0.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/SimpleResourceAllocationPolic
ies.java
changed 16.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ThresholdShedder.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/LeaderElectionService.java changed 0.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/LoadReportUpdaterTask.java changed 4.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/ModularLoadManager.java changed 5.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/LookupResult.java changed 45.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java changed 20.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/v1/TopicLookup.java changed 3.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/v2/TopicLookup.java changed 4.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java changed 23.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/MessagingServiceShutdownHook.java changed 7.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceEphemeralData.java changed 55.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java changed 10.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnedBundle.java changed 1.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnershipCache.java changed 3.1% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/NoOpShutdownService.java removed
pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlers.java changed 3.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlerUtils.java changed 13.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java changed 12.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractBaseDispatcher.java changed 60.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractDispatcherMultipleConsumers.ja
va
changed 8.1% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractDispatcherSingleActiveConsumer
.java
changed 9.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java changed 0.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java changed 14.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java changed 1.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java changed 10.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerServiceException.java changed 5.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsistentHashingStickyKeyConsumerSele
ctor.java
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java changed 12.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Dispatcher.java changed 6.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/EntryBatchIndexesAcks.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeAutoSplitStickyKeyConsumerSel
ector.java
changed 7.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeExclusiveStickyKeyConsumerSel
ector.java
changed 14.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcher.
java
changed 2.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherM
ultipleConsumers.java
changed 6.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherS
ingleActiveConsumer.java
changed 5.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentReplicator.
java
changed 0.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentStickyKeyDi
spatcherMultipleConsumers.java
changed 48.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscriptio
n.java
changed 20.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java changed 1.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/CompactorSubscription.java changed 1.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java changed 0.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipl
eConsumers.java
changed 7.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleA
ctiveConsumer.java
changed 7.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMoni
tor.java
changed 0.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java changed 2.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatch
erMultipleConsumers.java
changed 100.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java changed 5.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java changed 5.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/SystemTopic.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java changed 7.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiter.java changed 52.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorage.java changed 0.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/JsonSchemaCompatibilityCheck.ja
va
changed 1.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/LongSchemaVersion.java moved 3.7% diff
pulsar-common/src/main/java/org/apache/pulsar/common/schema/LongSchemaVersion.java
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java changed 0.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SendMessageInfo.java changed 4.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java changed 6.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/StickyKeyConsumerSelector.java changed 20.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/StreamingStats.java changed 2.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Subscription.java changed 1.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.j
ava
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Topic.java changed 3.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicPoliciesService.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/AggregatedNamespaceStats.java changed 3.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/DataSketchesOpStatsLo
gger.java
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/PrometheusMetricsProv
ider.java
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/PrometheusStatsLogger
.java
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/PrometheusTextFormatU
til.java
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/SimpleGauge.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/Summary.java changed 2.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/NamespaceStatsAggregator.java changed 0.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/PrometheusMetricsGenerator.ja
va
changed 85.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/NamespaceEventsSystemTopicFactory.jav
a
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClient.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClientBase.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/TopicPoliciesSystemTopicClient.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/TransactionMetadataStoreService.java changed 1.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/web/EventListenerFilter.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/web/MaxRequestSizeFilter.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java changed 17.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/web/WebService.java changed 4.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java changed 2.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/common/naming/PartitionedManagedLedgerInfo.java added
pulsar-broker/src/main/java/org/apache/pulsar/PulsarBrokerStarter.java changed 5.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java changed 2.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/utils/auth/tokens/TokensCliUtils.java changed 0.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/ZookeeperSessionExpiredHandlers.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiGetLastMessageIdTest.java changed 1.7% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiMaxUnackedMessages.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaValidationEnforced.java changed 1.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java changed 12.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest2.java changed 3.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminResourceTest.java changed 74.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminTest.java changed 18.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/BookiesApiTest.java changed 0.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/IncrementPartitionsTest.java changed 65.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java changed 8.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/PersistentTopicsTest.java changed 14.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v1/V1_AdminApiTest.java changed 0.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v1/V1_AdminApiTest2.java changed 0.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/AuthorizationTest.java changed 1.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java changed 27.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/BookKeeperClientFactoryImplTest.java changed 12.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/BrokerInterceptorTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/BrokerInterceptorUtilsTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/BrokerInterceptorWithClassLoaderTest
.java
added
pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/CounterBrokerInterceptor.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/MockBrokerInterceptor.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/AntiAffinityNamespaceGroupTest.jav
a
changed 1.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/LoadBalancerTest.java changed 0.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/ModularLoadManagerImplTest.java changed 0.8% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/SimpleLoadManagerImplTest.java changed 0.7% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/MockedBookKeeperClientFactory.java changed 14.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/namespace/NamespaceServiceTest.java changed 1.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/namespace/OwnershipCacheTest.java changed 2.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/protocol/ProtocolHandlerUtilsTest.java changed 6.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/AdvertisedAddressTest.java changed 3.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java changed 15.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BatchMessageTest.java changed 0.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BkEnsemblesTestBase.java changed 3.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerBkEnsemblesTests.java changed 13.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerBookieIsolationTest.java changed 1.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceAutoSubscriptionCreationT
est.java
added
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceAutoTopicCreationTest.jav
a
changed 5.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceThrottlingTest.java changed 3.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/CurrentLedgerRolloverIfFullTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/DistributedIdGeneratorTest.java changed 0.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/HashRangeAutoSplitStickyKeyConsumerSel
ectorTest.java
renamed 73.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ConsistentHashingStickyKeyConsumerSelectorTest.java
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/MaxMessageSizeTest.java changed 2.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/MessageIdSerialization.java changed 13.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/MessagePublishBufferThrottleTest.java changed 24.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/NonPersistentTopicE2ETest.java changed 2.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/NullValueTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PartitionKeyTest.java changed 3.8% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/ChecksumTest.java changed 0.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatch
erMultipleConsumersTest.java
added
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentSubscriptionTest.
java
changed 0.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentDispatcherFailoverConsumerTe
st.java
changed 0.7% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentTopicConcurrentTest.java changed 0.8% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentTopicE2ETest.java changed 0.01% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentTopicTest.java changed 0.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PrecisTopicPublishRateThrottleTest.jav
a
added
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PublishRateLimiterTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/RackAwareTest.java changed 1.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorGlobalNSTest.java changed 4.7% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTest.java changed 7.8% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTestBase.java changed 1.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ResendRequestTest.java changed 1.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorageTest.jav
a
changed 1.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/JsonSchemaCompatibilityCheckTes
t.java
changed 2.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/KeyValueSchemaCompatibilityChec
kTest.java
changed 0.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/SchemaServiceTest.java changed 0.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ServerCnxTest.java changed 4.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SubscriptionSeekTest.java changed 49.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesServiceTe
st.java
added
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TopicOwnerTest.java changed 2.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TopicPoliciesServiceDisableTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TopicTerminationTest.java changed 0.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/SLAMonitoringTest.java changed 1.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/PrometheusMetricsTest.java changed 22.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/systopic/NamespaceEventsSystemTopicServiceTest
.java
added
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/buffer/PersistentTransactionBuffer
Test.java
changed 1.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionMetaStoreTe
stBase.java
changed 3.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/web/WebServiceTest.java changed 22.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/zookeeper/ZooKeeperSessionExpireRecoveryTest.j
ava
changed 17.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/AuthenticatedProducerConsumerTest.java changed 0.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/AuthorizationProducerConsumerTest.java changed 13.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/BrokerServiceLookupTest.java changed 2.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientDeduplicationFailureTest.java changed 1.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientErrorsTest.java changed 0.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerCleanupTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerPreciseDispatcherFlowControl.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerRedeliveryTest.java changed 2.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/DeadLetterTopicTest.java changed 29.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java changed 66.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/MessageDispatchThrottlingTest.java changed 3.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/NonDurableSubscriptionTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/api/NonPersistentKeySharedSubscriptionTest.jav
a
removed
pulsar-broker/src/test/java/org/apache/pulsar/client/api/NonPersistentTopicTest.java changed 0.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/PartitionCreationTest.java changed 1.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ProducerCleanupTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ProxyProtocolTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/api/PulsarMultiListenersWithInternalListenerNa
meTest.java
added
pulsar-broker/src/test/java/org/apache/pulsar/client/api/PulsarMultiListenersWithoutInternalListene
rNameTest.java
added
pulsar-broker/src/test/java/org/apache/pulsar/client/api/RetryTopicTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java changed 1.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleSchemaTest.java changed 0.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/TlsHostVerification.java changed 5.7% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java changed 0.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BatchMessageIdImplSerializationTest.java changed 12.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BatchMessageIndexAckDisableTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BatchMessageIndexAckTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BrokerClientIntegrationTest.java changed 8.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/CompactedOutBatchMessageTest.java changed 2.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageChunkingTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PatternTopicsConsumerImplTest.java changed 2.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PerMessageUnAcknowledgedRedeliveryTest.ja
va
changed 0.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ProducerSemaphoreTest.java changed 91.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ReaderTest.java changed 30.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TopicDoesNotExistsTest.java changed 57.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TopicsConsumerImplTest.java changed 25.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/compaction/CompactedTopicTest.java changed 28.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/discovery/service/web/DiscoveryServiceWebTest.java changed 8.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionE2ESecurityTest.java changed 2.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionLocalRunTest.java changed 20.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionPublishTest.java changed 35.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarWorkerAssignmentTest.java changed 2.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionAdminTest.java changed 2.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionE2ETest.java changed 5.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionTlsTest.java changed 4.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/io/SinkForTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/schema/Schemas.java changed 19.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/websocket/proxy/ProxyPublishConsumeTest.java changed 0.2% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Bookies.java changed 64.3% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Brokers.java changed 95.9% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/BrokerStats.java changed 100.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Clusters.java changed 59.2% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Functions.java changed 77.8% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/BaseResource.java changed 6.8% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/BookiesImpl.java changed 100.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/BrokersImpl.java changed 100.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/BrokerStatsImpl.java changed 100.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/ClustersImpl.java changed 100.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/ComponentResource.java changed 11.9% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/FunctionsImpl.java changed 100.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.j
ava
changed 46.9% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnectorPr
ovider.java
changed 3.4% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/package-info.java added
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/JacksonConfigurator.java changed 4.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/LookupImpl.java changed 100.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/NamespacesImpl.java changed 100.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/NonPersistentTopicsImpl.j
ava
changed 0.4% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/package-info.java added
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/ProxyStatsImpl.java added
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/ResourceQuotasImpl.java changed 100.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SchemasImpl.java changed 100.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SinksImpl.java changed 100.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SourcesImpl.java changed 100.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TenantsImpl.java changed 100.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java changed 44.1% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/WebTargets.java changed 7.2% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/WorkerImpl.java changed 100.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/LongRunningProcessStatus.java changed 2.3% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Lookup.java changed 44.6% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Namespaces.java changed 83.8% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/NonPersistentTopics.java changed 2.7% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/OffloadProcessStatus.java changed 11.6% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/package-info.java added
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Properties.java changed 2.9% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/ProxyStats.java added
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/PulsarAdmin.java changed 2.5% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/PulsarAdminBuilder.java changed 4.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/PulsarAdminException.java changed 13.1% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/ResourceQuotas.java changed 71.8% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Schemas.java changed 68.6% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Sinks.java changed 72.9% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Sources.java changed 74.5% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Tenants.java changed 41.5% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Topics.java changed 34.9% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Worker.java changed 56.6% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ClientBuilder.java changed 5.6% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Consumer.java changed 23.3% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java changed 13.0% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/DeadLetterPolicy.java changed 14.6% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/KeySharedPolicy.java changed 27.0% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java changed 8.1% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProxyProtocol.java added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java changed 21.9% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Range.java changed 9.9% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ReaderBuilder.java changed 6.0% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaDefinition.java changed 20.9% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaDefinitionBuilder.java changed 14.4% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/DefaultImplementation.java changed 1.6% diff
pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/KeyValue.java changed 22.0% diff
pulsar-client-auth-sasl/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationSasl.java changed 1.4% diff
pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/producer/Puls
arKafkaProducer.java
changed 1.6% diff
pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/pulsar/client/kafka/compat/
PulsarProducerKafkaConfig.java
changed 11.6% diff
pulsar-client-kafka-compat/pulsar-client-kafka/src/test/java/org/apache/kafka/clients/producer/Puls
arKafkaProducerTest.java
changed 1.3% diff
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/producer/
PulsarKafkaProducer.java
changed 1.3% diff
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/kafka/clients/consumer/
PulsarKafkaConsumer.java
changed 0.2% diff
pulsar-client-messagecrypto-bc/src/main/java/org/apache/pulsar/client/impl/crypto/MessageCryptoBc.j
ava
changed 0.6% diff
pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/CmdFunctionsTest.java changed 37.6% diff
pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/PulsarAdminToolTest.java changed 8.5% diff
pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/utils/IOUtilsTest.java changed 1.0% diff
pulsar-client-tools-test/src/test/java/org/apache/pulsar/client/cli/PulsarClientToolTest.java changed 8.8% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CliCommand.java changed 1.8% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdClusters.java changed 5.6% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java changed 2.1% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdGenerateDocument.java changed 1.4% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java changed 7.9% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPersistentTopics.java changed 4.8% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdProxyStats.java added
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java changed 3.1% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java changed 6.1% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/PulsarAdminTool.java changed 0.8% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java changed 17.1% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java changed 12.3% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/PulsarClientTool.java changed 8.4% diff
pulsar-client-tools/src/test/java/org/apache/pulsar/admin/cli/TestCmdSinks.java changed 0.7% diff
pulsar-client-tools/src/test/java/org/apache/pulsar/admin/cli/TestCmdSources.java changed 0.7% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/AcknowledgmentsGroupingTracker.java changed 10.8% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationDisabled.java changed 4.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationToken.java changed 3.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java changed 1.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageIdImpl.java changed 7.9% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/BinaryProtoLookupService.java changed 12.9% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java changed 13.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java changed 0.8% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigurationData.java changed 10.5% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ConsumerConfigurationData.java changed 8.5% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ProducerConfigurationData.java changed 0.7% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ReaderConfigurationData.java changed 4.9% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionHandler.java changed 6.7% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionPool.java changed 21.5% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java changed 15.0% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java changed 19.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java changed 26.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java changed 0.6% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/HttpClient.java changed 3.9% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/HttpLookupService.java changed 1.5% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/LookupService.java changed 15.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageIdImpl.java changed 8.0% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java changed 8.8% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java changed 7.7% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/NegativeAcksTracker.java changed 7.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/NonPersistentAcknowledgmentGroupingTracke
r.java
changed 10.1% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PatternMultiTopicsConsumerImpl.java changed 4.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.
java
changed 96.0% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java changed 3.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java changed 15.9% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java changed 2.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarChannelInitializer.java changed 8.6% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java changed 3.3% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarServiceNameResolver.java changed 9.3% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderBuilderImpl.java changed 20.5% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java changed 4.3% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AbstractSchema.java changed 6.7% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericAvroReader.java changed 14.8% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericAvroSchema.java changed 5.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericJsonReader.java changed 3.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericJsonRecord.java changed 4.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/JSONSchema.java changed 18.6% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/KeyValueSchema.java changed 7.1% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/reader/AvroReader.java changed 2.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/reader/JacksonJsonReader.java added
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/reader/JsonReader.java changed 10.9% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/reader/ProtobufReader.java changed 4.0% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/SchemaDefinitionBuilderImpl.java changed 23.8% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/SchemaDefinitionImpl.java changed 28.7% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/StructSchema.java changed 8.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/writer/JacksonJsonWriter.java added
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/writer/JsonWriter.java changed 9.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java changed 0.6% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/TypedMessageBuilderImpl.java changed 9.7% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/UnAckedMessageTracker.java changed 9.1% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ZeroQueueConsumerImpl.java changed 1.5% diff
pulsar-client/src/main/java/org/apache/pulsar/client/util/RetryMessageUtil.java added
pulsar-client/src/test/java/org/apache/pulsar/client/api/SchemaDefinitionBuilderTest.java changed 100.0% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/AcknowledgementsGroupingTrackerTest.java changed 2.1% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/BatchMessageIdImplTest.java changed 2.5% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/BinaryProtoLookupServiceTest.java added
pulsar-client/src/test/java/org/apache/pulsar/client/impl/conf/ConfigurationDataUtilsTest.java changed 2.5% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/ConsumerBuilderImplTest.java changed 3.9% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/MessageIdCompareToTest.java changed 10.3% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/MessageImplTest.java changed 3.3% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImplTest.java changed 0.1% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/generic/GenericAvroReaderTest.java changed 25.5% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/JSONSchemaTest.java changed 3.4% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/KeyValueSchemaInfoTest.java changed 3.5% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/SchemaBuilderTest.java changed 0.4% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/SchemaInfoTest.java changed 0.4% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/SchemaTestUtils.java changed 3.5% diff
pulsar-client/src/test/java/org/apache/pulsar/client/tutorial/SampleConsumer.java changed 11.7% diff
pulsar-client/src/test/java/org/apache/pulsar/common/schema/KeyValueTest.java changed 0.2% diff
pulsar-common/src/main/java/io/airlift/compress/zstd/package-info.java added
pulsar-common/src/main/java/io/airlift/compress/zstd/ZStdRawCompressor.java added
pulsar-common/src/main/java/io/airlift/compress/zstd/ZStdRawDecompressor.java added
pulsar-common/src/main/java/org/apache/pulsar/common/api/proto/PulsarApi.java changed 1.8% diff
pulsar-common/src/main/java/org/apache/pulsar/common/api/raw/RawMessage.java changed 4.2% diff
pulsar-common/src/main/java/org/apache/pulsar/common/api/raw/RawMessageImpl.java changed 4.4% diff
pulsar-common/src/main/java/org/apache/pulsar/common/compression/CompressionCodecLZ4.java changed 82.1% diff
pulsar-common/src/main/java/org/apache/pulsar/common/compression/CompressionCodecSnappy.java changed 100.0% diff
pulsar-common/src/main/java/org/apache/pulsar/common/compression/CompressionCodecZstd.java changed 77.4% diff
pulsar-common/src/main/java/org/apache/pulsar/common/conf/InternalConfigurationData.java changed 23.6% diff
pulsar-common/src/main/java/org/apache/pulsar/common/events/ActionType.java added
pulsar-common/src/main/java/org/apache/pulsar/common/events/EventsTopicNames.java added
pulsar-common/src/main/java/org/apache/pulsar/common/events/EventType.java added
pulsar-common/src/main/java/org/apache/pulsar/common/events/package-info.java added
pulsar-common/src/main/java/org/apache/pulsar/common/events/PulsarEvent.java added
pulsar-common/src/main/java/org/apache/pulsar/common/events/TopicPoliciesEvent.java added
pulsar-common/src/main/java/org/apache/pulsar/common/functions/ConsumerConfig.java changed 18.1% diff
pulsar-common/src/main/java/org/apache/pulsar/common/functions/FunctionConfig.java changed 5.1% diff
pulsar-common/src/main/java/org/apache/pulsar/common/functions/FunctionDefinition.java added
pulsar-common/src/main/java/org/apache/pulsar/common/functions/FunctionState.java changed 10.4% diff
pulsar-common/src/main/java/org/apache/pulsar/common/functions/Resources.java changed 7.2% diff
pulsar-common/src/main/java/org/apache/pulsar/common/functions/WindowConfig.java changed 6.4% diff
pulsar-common/src/main/java/org/apache/pulsar/common/io/BatchSourceConfig.java added
pulsar-common/src/main/java/org/apache/pulsar/common/io/ConfigFieldDefinition.java added
pulsar-common/src/main/java/org/apache/pulsar/common/io/ConnectorDefinition.java changed 66.3% diff
pulsar-common/src/main/java/org/apache/pulsar/common/io/SinkConfig.java changed 6.1% diff
pulsar-common/src/main/java/org/apache/pulsar/common/io/SourceConfig.java changed 6.2% diff
pulsar-common/src/main/java/org/apache/pulsar/common/naming/TopicName.java changed 0.5% diff
pulsar-common/src/main/java/org/apache/pulsar/common/nar/NarClassLoader.java changed 10.0% diff
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/AutoSubscriptionCreationOverride
.java
added
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/ClusterData.java changed 33.4% diff
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/ConsumerStats.java changed 4.1% diff
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/NamespaceOperation.java added
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/Policies.java changed 17.9% diff
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyName.java added
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyOperation.java added
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PublisherStats.java changed 1.9% diff
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/SubscriptionStats.java changed 5.0% diff
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TenantOperation.java added
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicOperation.java added
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java added
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicStats.java changed 1.5% diff
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java changed 4.7% diff
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Markers.java changed 0.9% diff
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarDecoder.java changed 0.5% diff
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/schema/SchemaData.java changed 1.7% diff
pulsar-common/src/main/java/org/apache/pulsar/common/sasl/KerberosName.java changed 1.7% diff
pulsar-common/src/main/java/org/apache/pulsar/common/schema/package-info.java added
pulsar-common/src/main/java/org/apache/pulsar/common/stats/JvmDefaultGCMetricsLogger.java changed 1.6% diff
pulsar-common/src/main/java/org/apache/pulsar/common/util/ClassLoaderUtils.java added
pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/BitSetRecyclable.java added
pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentBitSet.java changed 1.2% diff
pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentBitSetRecyclable.ja
va
added
pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongHashMap.java changed 2.9% diff
pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongPairSet.java changed 1.9% diff
pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentOpenHashMap.java changed 2.3% diff
pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentOpenHashSet.java changed 2.8% diff
pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentSortedLongPairSet.j
ava
changed 5.1% diff
pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/GrowablePriorityLongPairQueue
.java
changed 2.9% diff
pulsar-common/src/main/java/org/apache/pulsar/common/util/FieldParser.java changed 0.5% diff
pulsar-common/src/main/java/org/apache/pulsar/common/util/RateLimiter.java changed 4.5% diff
pulsar-common/src/main/java/org/apache/pulsar/common/util/RateLimitFunction.java added
pulsar-common/src/main/java/org/apache/pulsar/common/util/RestException.java added
pulsar-common/src/main/java/org/apache/pulsar/common/util/SafeCollectionUtils.java added
pulsar-common/src/main/java/org/apache/pulsar/common/util/SearchBcNarUtils.java changed 2.0% diff
pulsar-common/src/main/java/org/apache/pulsar/common/util/SecurityUtility.java changed 2.5% diff
pulsar-common/src/main/java/org/apache/pulsar/common/validator/ConfigValidation.java added
pulsar-common/src/main/java/org/apache/pulsar/common/validator/ConfigValidationAnnotations.java added
pulsar-common/src/main/java/org/apache/pulsar/common/validator/ConfigValidationUtils.java added
pulsar-common/src/main/java/org/apache/pulsar/common/validator/package-info.java added
pulsar-common/src/main/java/org/apache/pulsar/common/validator/Validator.java added
pulsar-common/src/main/java/org/apache/pulsar/common/validator/ValidatorImpls.java added
pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/AdvertisedListener.java added
pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/LocalBrokerData.java changed 11.9% diff
pulsar-common/src/test/java/org/apache/pulsar/common/compression/CompressionCodecLZ4JNI.java added
pulsar-common/src/test/java/org/apache/pulsar/common/compression/CompressionCodecSnappyJNI.java added
pulsar-common/src/test/java/org/apache/pulsar/common/compression/CompressionCodecZstdJNI.java added
pulsar-common/src/test/java/org/apache/pulsar/common/compression/CompressorCodecBackwardCompatTest.
java
added
pulsar-common/src/test/java/org/apache/pulsar/common/compression/CompressorCodecTest.java changed 97.0% diff
pulsar-common/src/test/java/org/apache/pulsar/common/lookup/data/LookupDataTest.java changed 9.0% diff
pulsar-common/src/test/java/org/apache/pulsar/common/naming/NamespaceNameTest.java changed 0.5% diff
pulsar-common/src/test/java/org/apache/pulsar/common/naming/TopicNameTest.java changed 0.3% diff
pulsar-common/src/test/java/org/apache/pulsar/common/policies/data/ClusterDataTest.java changed 1.1% diff
pulsar-common/src/test/java/org/apache/pulsar/common/policies/data/NamespaceOwnershipStatusTest.jav
a
changed 1.9% diff
pulsar-common/src/test/java/org/apache/pulsar/common/policies/data/PoliciesDataTest.java changed 5.4% diff
pulsar-common/src/test/java/org/apache/pulsar/common/policies/impl/NamespaceIsolationPoliciesTest.j
ava
changed 0.1% diff
pulsar-common/src/test/java/org/apache/pulsar/common/policies/impl/NamespaceIsolationPolicyImplTest
.java
changed 0.1% diff
pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/BitSetRecyclableRecyclableTes
t.java
added
pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentBitSetRecyclableTes
t.java
added
pulsar-common/src/test/java/org/apache/pulsar/common/util/RateLimiterTest.java changed 9.5% diff
pulsar-common/src/test/java/org/apache/pulsar/common/validator/ConfigValidationTest.java added
pulsar-common/src/test/java/org/apache/pulsar/common/validator/ValidatorImplsTest.java added
pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/BrokerDiscoveryProvider.
java
changed 4.4% diff
pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/DiscoveryService.java changed 0.8% diff
pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/server/ServerManager.jav
a
changed 0.9% diff
pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/server/ServiceConfig.jav
a
changed 1.8% diff
pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/web/DiscoveryServiceServ
let.java
changed 0.8% diff
pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/web/RestException.java removed
pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/web/ZookeeperCacheLoader
.java
changed 18.8% diff
pulsar-discovery-service/src/test/java/org/apache/pulsar/discovery/service/BaseDiscoveryTestSetup.j
ava
changed 5.8% diff
pulsar-discovery-service/src/test/java/org/apache/pulsar/discovery/service/DiscoveryServiceTest.jav
a
changed 3.8% diff
pulsar-discovery-service/src/test/java/org/apache/pulsar/discovery/service/web/BaseZKStarterTest.ja
va
changed 5.2% diff
pulsar-discovery-service/src/test/java/org/apache/pulsar/discovery/service/web/DiscoveryServiceWebT
est.java
changed 6.6% diff
pulsar-discovery-service/src/test/java/org/apache/pulsar/discovery/service/web/ZookeeperCacheLoader
Test.java
changed 1.3% diff
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/CachedPulsarClient.java changed 12.8% diff
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarProducer.java changed 11.5% diff
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/partitioner/PulsarPropertie
sExtractor.java
added
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarAvroTableSink.java changed 3.7% diff
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSource.java changed 0.9% diff
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarTableSink.java changed 4.2% diff
pulsar-flink/src/test/java/org/apache/flink/streaming/connectors/pulsar/CachedPulsarClientTest.java changed 1.3% diff
pulsar-flink/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarAvroTableSinkTest.jav
a
changed 6.7% diff
pulsar-flink/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSourceTests.j
ava
changed 6.6% diff
pulsar-flink/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarJsonTableSinkTest.jav
a
changed 6.9% diff
pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Context.java changed 4.9% diff
pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/KVRecord.java added
pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Record.java changed 3.7% diff
pulsar-functions/api-java/src/test/java/org/apache/pulsar/functions/api/utils/JavaSerDeTest.java changed 6.0% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/AuthenticationConfig.j
ava
changed 10.8% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java changed 5.1% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/go/GoInstanceConfig.ja
va
changed 2.2% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceConfig.java changed 7.7% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceUtils.java changed 0.9% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaExecutionResult.ja
va
changed 4.8% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.j
ava
changed 8.7% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/SinkRecord.java changed 33.4% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java changed 17.3% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSinkConfig.java changed 10.0% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java changed 6.6% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSourceConfig.java changed 2.2% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/TopicSchema.java changed 22.9% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/evictors/WatermarkCou
ntEvictionPolicy.java
changed 7.7% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFunctionExecuto
r.java
changed 0.4% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowManager.java changed 0.8% diff
pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/instance/JavaInstanceRunnableTe
st.java
changed 1.6% diff
pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/ConfigBasedAp
pendFunction.java
changed 10.7% diff
pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/pojo/AvroTest
Object.java
changed 3.4% diff
pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/pojo/Tick.jav
a
changed 6.6% diff
pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java changed 12.1% diff
pulsar-functions/runtime-all/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceMain.ja
va
changed 1.8% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/FunctionAuthProvider.java changed 1.9% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/FunctionAuthUtils.java changed 15.8% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesFunctionAuthProvi
der.java
changed 7.7% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesSecretsTokenAuthP
rovider.java
changed 1.3% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/JavaInstanceStarter.java changed 2.5% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/BasicKubernet
esManifestCustomizer.java
changed 29.4% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRun
time.java
changed 1.0% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRun
timeFactory.java
changed 2.3% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRun
timeFactoryConfig.java
changed 11.1% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/process/ProcessRuntime.j
ava
changed 2.5% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/process/ProcessRuntimeFa
ctory.java
changed 4.0% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/process/ProcessRuntimeFa
ctoryConfig.java
changed 2.1% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeCustomizer.java changed 4.5% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeFactory.java changed 1.9% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeUtils.java changed 3.3% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntime.jav
a
changed 5.7% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntimeFact
ory.java
changed 34.3% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntimeFact
oryConfig.java
changed 3.0% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java changed 9.2% diff
pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRun
timeTest.java
changed 4.9% diff
pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/runtime/process/ProcessRuntimeTe
st.java
changed 2.1% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/functioncache/FunctionCacheE
ntry.java
changed 7.3% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/functioncache/FunctionCacheM
anager.java
changed 8.1% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/functioncache/FunctionCacheM
anagerImpl.java
changed 6.2% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionCommon.java changed 12.1% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java changed 10.1% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionMetaDataUtils.java added
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/functions/Functions.java added
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/functions/FunctionUtils.java added
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/io/Connectors.java changed 19.3% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/io/ConnectorUtils.java changed 65.0% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/Reflections.java moved 8.9% diff
pulsar-common/src/main/java/org/apache/pulsar/common/util/Reflections.java
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java changed 12.6% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfigUtils.java changed 44.7% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/ValidatorUtils.java changed 4.2% diff
pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/FunctionConfigUtilsTest.java changed 0.9% diff
pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/FunctionMetaDataUtilsTest.ja
va
added
pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/ReflectionsTest.java moved 1.9% diff
pulsar-common/src/test/java/org/apache/pulsar/common/util/ReflectionsTest.java
pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/SinkConfigUtilsTest.java changed 16.0% diff
pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/SourceConfigUtilsTest.java changed 68.0% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/ClusterServiceCoordinator.
java
changed 2.7% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/ConnectorsManager.java changed 35.5% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/ErrorNotifier.java added
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/ErrorNotifierImpl.java added
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/ErrorNotifierShutdownServi
ceImpl.java
added
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionActioner.java changed 21.8% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionAssignmentTailer.j
ava
changed 62.3% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionMetaDataManager.ja
va
changed 15.3% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionMetaDataTopicTaile
r.java
changed 5.8% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeInfo.java changed 2.8% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.jav
a
changed 3.5% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionsManager.java added
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionWorkerStarter.java changed 3.6% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/request/ServiceRequestInfo
.java
changed 7.0% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.jav
a
changed 3.5% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.jav
a
changed 3.7% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImplV2.j
ava
changed 0.5% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsMetricsR
esource.java
changed 49.2% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SinksImpl.java changed 4.5% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SourcesImpl.java changed 4.4% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionsApiV2
Resource.java
changed 2.6% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionsApiV3
Resource.java
changed 3.0% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/SinksApiV3Reso
urce.java
changed 18.3% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/SourcesApiV3Re
source.java
changed 16.1% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/WorkerImpl.java changed 0.7% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/RestException.java removed
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/RestUtils.java changed 3.2% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/WorkerServer.java changed 7.8% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java changed 1.3% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/Worker.java changed 11.5% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerService.java changed 15.1% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerUtils.java changed 8.6% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/executor/MockExecutorContr
oller.java
changed 0.2% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/FunctionActionerTest.java changed 3.1% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/FunctionMetaDataManagerTes
t.java
changed 2.1% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/FunctionRuntimeManagerTest
.java
changed 18.7% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/MembershipManagerTest.java changed 2.3% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImplTest
.java
changed 8.3% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionApiV2R
esourceTest.java
changed 1.8% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionApiV3R
esourceTest.java
changed 1.8% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v3/SinkApiV3Resou
rceTest.java
changed 1.1% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v3/SourceApiV3Res
ourceTest.java
changed 1.0% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/SchedulerManagerTest.java changed 3.2% diff
pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeAbstractSink.java changed 3.8% diff
pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws/AbstractAwsConnector.java added
pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws/AwsCredentialProviderPlugin.java added
pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws/AwsDefaultProviderChainPlugin.java added
pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws/STSAssumeRoleProviderPlugin.java added
pulsar-io/batch-data-generator/src/main/java/org/apache/pulsar/io/batchdatagenerator/BatchDataGener
atorPrintSink.java
added
pulsar-io/batch-data-generator/src/main/java/org/apache/pulsar/io/batchdatagenerator/BatchDataGener
atorSource.java
added
pulsar-io/batch-data-generator/src/main/java/org/apache/pulsar/io/batchdatagenerator/Person.java added
pulsar-io/batch-data-generator/src/test/java/org/apache/pulsar/io/batchdatagenerator/BatchDataGener
atorExec.java
added
pulsar-io/batch-discovery-triggerers/src/main/java/org/apache/pulsar/io/batchdiscovery/CronTriggere
r.java
added
pulsar-io/batch/src/main/java/org/apache/pulsar/io/batch/BatchSourceExecutor.java added
pulsar-io/batch/src/test/java/org/apache/pulsar/io/batch/BatchSourceExecutorTest.java added
pulsar-io/common/src/main/java/org/apache/pulsar/io/common/IOConfigUtils.java changed 14.6% diff
pulsar-io/common/src/test/java/org/apache/pulsar/io/common/IOConfigUtilsTest.java changed 4.9% diff
pulsar-io/core/src/main/java/org/apache/pulsar/io/core/BatchSource.java added
pulsar-io/core/src/main/java/org/apache/pulsar/io/core/BatchSourceTriggerer.java added
pulsar-io/core/src/main/java/org/apache/pulsar/io/core/SourceContext.java changed 22.6% diff
pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistory.java changed 2.7% diff
pulsar-io/debezium/core/src/test/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistoryTest.java changed 2.5% diff
pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSource.java added
pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfig.java added
pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/StreamsRecord.java added
pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/StreamsRecordProcessor.java added
pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/StreamsRecordProcessorFactory.java added
pulsar-io/dynamodb/src/test/java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfigTests.java added
pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchConfig.java changed 10.5% diff
pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java changed 1.5% diff
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/ElasticSearchConfigTests.
java
changed 12.5% diff
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java changed 1.3% diff
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink/SourceOfFlume.java changed 2.1% diff
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/node/TestPollingPropertiesFileConfiguratio
nProvider.java
changed 0.4% diff
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsSequentialTextSink.java changed 2.7% diff
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsTextSink.java changed 7.7% diff
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/text/HdfsStringSink.java changed 11.0% diff
pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/seq/HdfsSequentialTextSink.java changed 2.7% diff
pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/seq/HdfsTextSink.java changed 7.7% diff
pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/text/HdfsStringSink.java changed 11.0% diff
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/BatchSink.java added
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBAbstractSink.java moved 57.2% diff
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBAbstractSink.java
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBBuilder.java moved 4.6% diff
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBBuilder.java
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBBuilderImpl.java moved 2.0% diff
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBBuilderImpl.java
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBGenericRecordSink.java changed 74.4% diff
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBSinkConfig.java removed
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBGenericRecordSink.java added
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBSinkConfig.java added
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBClientBuilder.java added
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBClientBuilderImpl.java added
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSink.java added
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSinkConfig.java added
pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/InfluxDBGenericRecordSinkTest.java changed 82.7% diff
pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/InfluxDBSinkConfigTest.java removed
pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/v1/InfluxDBGenericRecordSinkTest.jav
a
added
pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/v1/InfluxDBSinkConfigTest.java added
pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSinkConfigTest.java added
pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSinkTest.java added
pulsar-io/jdbc/clickhouse/src/main/java/org/apache/pulsar/io/jdbc/ClickHouseJdbcAutoSchemaSink.java added
pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java added
pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcDriverType.java added
pulsar-io/jdbc/mariadb/src/main/java/org/apache/pulsar/io/jdbc/MariadbJdbcAutoSchemaSink.java added
pulsar-io/jdbc/postgres/src/main/java/org/apache/pulsar/io/jdbc/PostgresJdbcAutoSchemaSink.java added
pulsar-io/jdbc/sqlite/src/main/java/org/apache/pulsar/io/jdbc/SqliteJdbcAutoSchemaSink.java added
pulsar-io/jdbc/sqlite/src/test/java/org/apache/pulsar/io/jdbc/SqliteJdbcSinkTest.java added
pulsar-io/jdbc/src/main/java/org/apache/pulsar/io/jdbc/JdbcAbstractSink.java moved 13.2% diff
pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcAbstractSink.java
pulsar-io/jdbc/src/main/java/org/apache/pulsar/io/jdbc/JdbcAutoSchemaSink.java removed
pulsar-io/jdbc/src/main/java/org/apache/pulsar/io/jdbc/JdbcSinkConfig.java moved 1.1% diff
pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcSinkConfig.java
pulsar-io/jdbc/src/main/java/org/apache/pulsar/io/jdbc/JdbcUtils.java moved 13.1% diff
pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcUtils.java
pulsar-io/jdbc/src/test/java/org/apache/pulsar/io/jdbc/JdbcSinkTest.java removed
pulsar-io/jdbc/src/test/java/org/apache/pulsar/io/jdbc/JdbcUtilsTest.java moved 2.2% diff
pulsar-io/jdbc/sqlite/src/test/java/org/apache/pulsar/io/jdbc/JdbcUtilsTest.java
pulsar-io/jdbc/src/test/java/org/apache/pulsar/io/jdbc/SqliteUtils.java moved 4.7% diff
pulsar-io/jdbc/sqlite/src/test/java/org/apache/pulsar/io/jdbc/SqliteUtils.java
pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConne
ctSource.java
added
pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSource
.java
changed 81.6% diff
pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema/KafkaSchema
WrappedSchema.java
added
pulsar-io/kafka/src/test/java/org/apache/pulsar/io/kafka/source/KafkaAbstractSourceTest.java changed 7.5% diff
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/AbstractKinesisConnector.java removed
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/AwsCredentialProviderPlugin.java changed 72.8% diff
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/AwsDefaultProviderChainPlugin.java changed 48.2% diff
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSink.java changed 2.2% diff
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSource.java changed 3.3% diff
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSourceConfig.java changed 0.8% diff
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/STSAssumeRoleProviderPlugin.java changed 67.3% diff
pulsar-io/kinesis/src/test/java/org/apache/pulsar/io/kinesis/KinesisSinkTest.java changed 1.0% diff
pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQAbstractConfig.java changed 4.9% diff
pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSink.java changed 25.8% diff
pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSinkConfig.java changed 12.6% diff
pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSourceConfig.java changed 10.7% diff
pulsar-io/rabbitmq/src/test/java/org/apache/pulsar/io/rabbitmq/sink/RabbitMQSinkConfigTest.java changed 8.3% diff
pulsar-io/rabbitmq/src/test/java/org/apache/pulsar/io/rabbitmq/sink/RabbitMQSinkTest.java changed 14.3% diff
pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java changed 1.0% diff
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataStore.java changed 1.9% diff
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/zookeeper/ZKMetadataStore.java changed 56.9% diff
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/BrokerDiscoveryProvider.java changed 4.5% diff
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java changed 5.4% diff
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java changed 0.4% diff
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ParserProxyHandler.java changed 22.9% diff
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConfiguration.java changed 3.1% diff
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java changed 2.4% diff
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java changed 16.5% diff
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyServiceStarter.java changed 4.9% diff
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/stats/ConnectionStats.java added
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/stats/ProxyStats.java added
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/stats/RestException.java added
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/stats/TopicStats.java added
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyIsAHttpProxyTest.java changed 3.3% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyKeyStoreTlsTestWithAuth.java changed 1.4% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyKeyStoreTlsTestWithoutAuth.java changed 1.5% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyParserTest.java changed 4.3% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyStatsTest.java added
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyTest.java changed 11.8% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyTlsTest.java changed 2.4% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/AvroSchemaHandler.java changed 59.6% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/JSONSchemaHandler.java changed 3.3% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/KeyValueSchemaHandler.java changed 37.7% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnector.java changed 3.6% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java changed 10.2% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorConfig.java changed 3.8% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorFactory.java changed 5.9% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorMetricsTracker.j
ava
changed 5.3% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarPrimitiveSchemaHandler.ja
va
changed 22.8% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java changed 4.3% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSchemaHandlers.java changed 51.7% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.jav
a
added
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/SchemaHandler.java changed 51.7% diff
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestAvroSchemaHandler.java added
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarConnector.java changed 0.1% diff
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarKeyValueSchemaHandler
.java
changed 16.4% diff
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarMetadata.java changed 4.5% diff
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarPrimitiveSchemaHandle
r.java
changed 0.5% diff
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarRecordCursor.java changed 7.3% diff
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarSplitManager.java changed 2.2% diff
pulsar-storm/src/main/java/org/apache/pulsar/storm/MessageToValuesMapper.java changed 8.4% diff
pulsar-storm/src/main/java/org/apache/pulsar/storm/PulsarSpout.java changed 1.2% diff
pulsar-storm/src/main/java/org/apache/pulsar/storm/PulsarTuple.java added
pulsar-storm/src/test/java/org/apache/pulsar/storm/PulsarSpoutTest.java changed 28.2% diff
pulsar-testclient/src/main/java/org/apache/pulsar/testclient/BrokerMonitor.java changed 0.3% diff
pulsar-testclient/src/main/java/org/apache/pulsar/testclient/ManagedLedgerWriter.java changed 0.2% diff
pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java changed 19.1% diff
pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java changed 2.2% diff
pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java changed 5.4% diff
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/AbstractWebSocketHandler.java changed 13.1% diff
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/admin/RestException.java removed
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/admin/WebSocketProxyStatsBase.java changed 1.1% diff
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/admin/WebSocketWebResource.java changed 1.0% diff
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/service/ProxyServer.java changed 12.2% diff
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/service/WebSocketProxyConfiguration.java changed 5.9% diff
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketConsumerServlet.java changed 5.6% diff
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketProducerServlet.java changed 5.6% diff
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketReaderServlet.java changed 5.6% diff
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketService.java changed 1.3% diff
pulsar-websocket/src/test/java/org/apache/pulsar/websocket/AbstractWebSocketHandlerTest.java added
pulsar-websocket/src/test/java/org/apache/pulsar/websocket/admin/WebSocketWebResourceTest.java changed 0.6% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/GlobalZooKeeperCache.java changed 2.6% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsemble.java changed 0.6% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/LocalZooKeeperConnectionService.ja
va
changed 2.1% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZkBookieRackAffinityMapping.java changed 16.2% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementP
olicy.java
changed 0.5% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZooKeeperCache.java changed 15.5% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZooKeeperDataCache.java changed 0.9% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZookeeperSessionExpiredHandler.jav
a
added
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZooKeeperSessionWatcher.java changed 8.7% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/DeserializersTest.java changed 6.1% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsembleTest.java changed 4.1% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/LocalZooKeeperConnectionServiceTes
t.java
changed 16.7% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/ZookeeperBkClientFactoryImplTest.j
ava
changed 4.9% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/ZookeeperCacheTest.java changed 6.0% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/ZookeeperClientFactoryImplTest.jav
a
changed 5.2% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/ZooKeeperSessionWatcherTest.java changed 33.9% diff
testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockBookKeeper.java changed 7.8% diff
testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockLedgerHandle.java changed 0.2% diff
testmocks/src/main/java/org/apache/zookeeper/MockZooKeeper.java changed 18.2% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/auth/token/TokenAuthWithSymmetr
icKeys.java
changed 12.4% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/FunctionsCLITest.java changed 2.3% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/ChaosContainer.java changed 1.0% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.j
ava
changed 12.6% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTestBa
se.java
changed 4.6% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/utils/CommandGenerato
r.java
changed 21.1% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/DebeziumMongoDbSourceTester.
java
changed 1.2% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/DebeziumMySqlSourceTester.ja
va
changed 7.3% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/DebeziumPostgreSqlSourceTest
er.java
changed 1.3% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/JdbcSinkTester.java renamed 30.4% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/JdbcPostgresSinkTester.java
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/SinkTester.java changed 11.4% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/SourceTester.java changed 66.6% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/schema/Schemas.java changed 11.6% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarTestBase.java changed 0.9% diff
tests/pulsar-kafka-compat-client-test/src/test/java/org/apache/pulsar/tests/integration/compat/kafk
a/KafkaApiTest.java
changed 0.2% diff
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBack
edReadHandleImpl.java
changed 0.8% diff
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreMana
gedLedgerOffloader.java
changed 0.9% diff
tiered-storage/jcloud/src/test/java/org/apache/bookkeeper/mledger/offload/jcloud/BlobStoreBackedInp
utStreamTest.java
changed 1.5% diff
tiered-storage/jcloud/src/test/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreMana
gedLedgerOffloaderTest.java
changed 0.2% diff

Python Programs (6 of 60):

NameStatusDeltaVisual Diff
docker/pulsar/scripts/apply-config-from-env.py changed 10.3% diff
pulsar-client-cpp/python/pulsar/__init__.py changed 3.7% diff
pulsar-client-cpp/python/pulsar/schema/definition.py changed 63.8% diff
pulsar-client-cpp/python/pulsar_test.py changed 4.7% diff
pulsar-client-cpp/python/schema_test.py changed 21.8% diff
pulsar-client-cpp/python/setup.py changed 19.4% diff

Shell Programs (29 of 75):

NameStatusDeltaVisual Diff
bin/bookkeeper changed 0.5% diff
bin/function-localrunner changed 1.7% diff
bin/pulsar changed 3.3% diff
bin/pulsar-admin changed 4.1% diff
bin/pulsar-client changed 1.1% diff
bin/pulsar-daemon changed 0.7% diff
bin/pulsar-perf changed 0.6% diff
conf/bkenv.sh changed 13.3% diff
conf/pulsar_env.sh changed 12.5% diff
deployment/kubernetes/helm/hack/common.sh added
deployment/kubernetes/helm/hack/kind-cluster-build.sh added
deployment/kubernetes/helm/scripts/cert-manager/install-cert-manager.sh added
deployment/kubernetes/helm/scripts/pulsar/clean_tls.sh added
deployment/kubernetes/helm/scripts/pulsar/cleanup_helm_release.sh added
deployment/kubernetes/helm/scripts/pulsar/common.sh added
deployment/kubernetes/helm/scripts/pulsar/common_auth.sh added
deployment/kubernetes/helm/scripts/pulsar/generate_token.sh added
deployment/kubernetes/helm/scripts/pulsar/generate_token_secret_key.sh added
deployment/kubernetes/helm/scripts/pulsar/get_token.sh added
deployment/kubernetes/helm/scripts/pulsar/prepare_helm_release.sh added
deployment/kubernetes/helm/scripts/pulsar/upload_tls.sh added
deployment/terraform-ansible/templates/pulsar_env.sh changed 11.6% diff
pulsar-client-cpp/docker/alpine/build-alpine-image.sh added
pulsar-client-cpp/docker/alpine/build-wheel-file-within-docker.sh added
pulsar-client-cpp/docker/alpine/build-wheel.sh added
pulsar-client-cpp/pkg/apk/build-apk.sh added
pulsar-client-cpp/pkg/apk/docker-build-apk.sh added
pulsar-client-cpp/run-unit-tests.sh changed 4.5% diff
pulsar-function-go/pb/generate.sh changed 1.7% diff

CMake Files (3 of 7):

NameStatusDeltaVisual Diff
pulsar-client-cpp/CMakeLists.txt changed 4.7% diff
pulsar-client-cpp/lib/CMakeLists.txt changed 12.5% diff
pulsar-client-cpp/tests/CMakeLists.txt changed 15.7% diff

Configuration Files (7 of 42):

NameStatusDeltaVisual Diff
conf/bookkeeper.conf changed 3.0% diff
conf/broker.conf changed 17.3% diff
conf/discovery.conf changed 2.7% diff
conf/proxy.conf changed 12.3% diff
conf/standalone.conf changed 14.5% diff
conf/websocket.conf changed 4.7% diff
deployment/terraform-ansible/templates/broker.conf changed 1.0% diff

JSON Files (5 of 14):

NameStatusDeltaVisual Diff
docker/grafana/dashboards/bookkeeper.json changed 0.1% diff
docker/grafana/dashboards/jvm.json changed 0.05% diff
docker/grafana/dashboards/namespace.json changed 0.1% diff
docker/grafana/dashboards/topic.json changed 0.1% diff
docker/grafana/dashboards/zookeeper.json changed 0.1% diff

SGML Documents (5 of 6):

NameStatusDeltaVisual Diff
dashboard/pom.xml.versionsBackup added
docker/grafana/pom.xml.versionsBackup added
docker/pulsar-all/pom.xml.versionsBackup added
docker/pulsar-standalone/pom.xml.versionsBackup added
docker/pulsar/pom.xml.versionsBackup added

XML Documents (142 of 190):

NameStatusDeltaVisual Diff
bouncy-castle/bc-shaded/pom.xml changed 3.0% diff
bouncy-castle/bc/pom.xml changed 1.5% diff
bouncy-castle/bcfips-include-test/pom.xml changed 1.0% diff
bouncy-castle/bcfips-nar-test/pom.xml changed 0.9% diff
bouncy-castle/bcfips/pom.xml changed 1.5% diff
bouncy-castle/pom.xml changed 1.7% diff
buildtools/pom.xml changed 1.1% diff
buildtools/src/main/resources/pulsar/suppressions.xml changed 3.3% diff
dashboard/pom.xml changed 0.8% diff
distribution/io/pom.xml changed 0.7% diff
distribution/io/src/assemble/io.xml changed 13.0% diff
distribution/offloaders/pom.xml changed 1.3% diff
distribution/pom.xml changed 1.8% diff
distribution/server/pom.xml changed 0.4% diff
docker/grafana/pom.xml changed 0.9% diff
docker/pom.xml changed 1.7% diff
docker/pom.xml.versionsBackup added
docker/pulsar-all/pom.xml changed 0.5% diff
docker/pulsar-standalone/pom.xml changed 0.8% diff
docker/pulsar/pom.xml changed 0.4% diff
examples/flink/pom.xml changed 1.1% diff
examples/pom.xml changed 2.1% diff
examples/spark/pom.xml changed 1.4% diff
jclouds-shaded/pom.xml removed
kafka-connect-avro-converter-shaded/pom.xml added
managed-ledger/pom.xml changed 4.9% diff
pom.xml changed 4.7% diff
protobuf-shaded/pom.xml changed 2.2% diff
pulsar-broker-auth-athenz/pom.xml changed 1.6% diff
pulsar-broker-auth-sasl/pom.xml changed 1.0% diff
pulsar-broker-common/pom.xml changed 1.4% diff
pulsar-broker-shaded/pom.xml changed 0.2% diff
pulsar-broker/pom.xml changed 0.2% diff
pulsar-client-1x-base/pom.xml changed 2.1% diff
pulsar-client-1x-base/pulsar-client-1x/pom.xml changed 1.7% diff
pulsar-client-1x-base/pulsar-client-2x-shaded/pom.xml changed 0.9% diff
pulsar-client-admin-shaded/pom.xml changed 0.3% diff
pulsar-client-admin/pom.xml changed 14.6% diff
pulsar-client-all/pom.xml changed 0.2% diff
pulsar-client-api/pom.xml changed 1.2% diff
pulsar-client-auth-athenz/pom.xml changed 1.5% diff
pulsar-client-auth-sasl/pom.xml changed 1.5% diff
pulsar-client-kafka-compat/pom.xml changed 1.5% diff
pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml changed 0.2% diff
pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml changed 0.1% diff
pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml changed 0.2% diff
pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml changed 1.3% diff
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/pom.xml changed 1.2% diff
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/pom.xml changed 1.3% diff
pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml changed 1.3% diff
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml changed 0.9% diff
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml changed 1.3% diff
pulsar-client-messagecrypto-bc/pom.xml changed 1.7% diff
pulsar-client-shaded/pom.xml changed 0.2% diff
pulsar-client-tools-test/pom.xml changed 9.2% diff
pulsar-client-tools/pom.xml changed 0.9% diff
pulsar-client/pom.xml changed 0.4% diff
pulsar-common/pom.xml changed 13.6% diff
pulsar-discovery-service/pom.xml changed 0.7% diff
pulsar-flink/pom.xml changed 6.5% diff
pulsar-functions/api-java/pom.xml changed 1.7% diff
pulsar-functions/instance/pom.xml changed 0.5% diff
pulsar-functions/java-examples/pom.xml changed 1.7% diff
pulsar-functions/localrun-shaded/pom.xml changed 4.2% diff
pulsar-functions/localrun/pom.xml changed 10.1% diff
pulsar-functions/pom.xml changed 1.8% diff
pulsar-functions/proto/pom.xml changed 1.0% diff
pulsar-functions/runtime-all/pom.xml changed 0.9% diff
pulsar-functions/runtime/pom.xml changed 0.9% diff
pulsar-functions/secrets/pom.xml changed 1.7% diff
pulsar-functions/utils/pom.xml changed 1.0% diff
pulsar-functions/worker/pom.xml changed 0.5% diff
pulsar-io/aerospike/pom.xml changed 1.4% diff
pulsar-io/aws/pom.xml added
pulsar-io/batch-data-generator/pom.xml added
pulsar-io/batch-discovery-triggerers/pom.xml added
pulsar-io/batch/pom.xml added
pulsar-io/canal/pom.xml changed 1.4% diff
pulsar-io/cassandra/pom.xml changed 1.4% diff
pulsar-io/common/pom.xml changed 13.0% diff
pulsar-io/core/pom.xml changed 2.1% diff
pulsar-io/data-generator/pom.xml changed 1.6% diff
pulsar-io/debezium/core/pom.xml changed 1.0% diff
pulsar-io/debezium/mongodb/pom.xml changed 1.7% diff
pulsar-io/debezium/mysql/pom.xml changed 1.6% diff
pulsar-io/debezium/pom.xml changed 2.1% diff
pulsar-io/debezium/postgres/pom.xml changed 1.6% diff
pulsar-io/docs/pom.xml changed 17.0% diff
pulsar-io/dynamodb/pom.xml added
pulsar-io/elastic-search/pom.xml changed 1.1% diff
pulsar-io/file/pom.xml changed 1.4% diff
pulsar-io/flume/pom.xml changed 0.9% diff
pulsar-io/hbase/pom.xml changed 1.1% diff
pulsar-io/hdfs2/pom.xml changed 1.4% diff
pulsar-io/hdfs3/pom.xml changed 1.5% diff
pulsar-io/influxdb/pom.xml changed 15.8% diff
pulsar-io/jdbc/clickhouse/pom.xml added
pulsar-io/jdbc/core/pom.xml added
pulsar-io/jdbc/mariadb/pom.xml added
pulsar-io/jdbc/pom.xml changed 58.2% diff
pulsar-io/jdbc/postgres/pom.xml added
pulsar-io/jdbc/sqlite/pom.xml added
pulsar-io/kafka-connect-adaptor/pom.xml changed 14.8% diff
pulsar-io/kafka/pom.xml changed 1.5% diff
pulsar-io/kinesis/pom.xml changed 11.3% diff
pulsar-io/mongo/pom.xml changed 1.3% diff
pulsar-io/netty/pom.xml changed 1.2% diff
pulsar-io/pom.xml changed 9.8% diff
pulsar-io/rabbitmq/pom.xml changed 1.0% diff
pulsar-io/redis/pom.xml changed 1.0% diff
pulsar-io/solr/pom.xml changed 1.1% diff
pulsar-io/twitter/pom.xml changed 1.2% diff
pulsar-log4j2-appender/pom.xml changed 1.2% diff
pulsar-metadata/pom.xml changed 1.8% diff
pulsar-proxy/pom.xml changed 0.6% diff
pulsar-spark/pom.xml changed 0.9% diff
pulsar-sql/pom.xml changed 0.6% diff
pulsar-sql/presto-distribution/pom.xml changed 0.3% diff
pulsar-sql/presto-pulsar-plugin/pom.xml changed 1.3% diff
pulsar-sql/presto-pulsar/pom.xml changed 1.7% diff
pulsar-storm/pom.xml changed 1.3% diff
pulsar-testclient/pom.xml changed 1.0% diff
pulsar-transaction/common/pom.xml changed 1.3% diff
pulsar-transaction/coordinator/pom.xml changed 1.9% diff
pulsar-transaction/pom.xml changed 1.4% diff
pulsar-websocket/pom.xml changed 0.8% diff
pulsar-zookeeper-utils/pom.xml changed 0.6% diff
pulsar-zookeeper/pom.xml changed 0.7% diff
testmocks/pom.xml changed 3.1% diff
tests/bc_2_0_0/pom.xml changed 4.1% diff
tests/bc_2_0_1/pom.xml changed 4.1% diff
tests/docker-images/java-test-functions/pom.xml changed 2.4% diff
tests/docker-images/latest-version-image/pom.xml changed 20.4% diff
tests/docker-images/pom.xml changed 5.0% diff
tests/integration/pom.xml changed 5.3% diff
tests/pom.xml changed 1.6% diff
tests/pulsar-kafka-compat-client-test/pom.xml changed 0.7% diff
tests/pulsar-spark-test/pom.xml changed 5.0% diff
tests/pulsar-storm-test/pom.xml changed 0.9% diff
tiered-storage/file-system/pom.xml changed 0.9% diff
tiered-storage/jcloud/pom.xml changed 56.1% diff
tiered-storage/pom.xml changed 9.7% diff

Property Files (3 of 10):

NameStatusDeltaVisual Diff
conf/presto/catalog/pulsar.properties changed 6.7% diff
pulsar-client-admin/src/main/resources/org/asynchttpclient/config/ahc-default.properties changed 4.7% diff
pulsar-client/src/main/resources/ahc.properties changed 5.0% diff

Protocol Buffer Files (3 of 11):

NameStatusDeltaVisual Diff
managed-ledger/src/main/proto/MLDataFormats.proto changed 16.0% diff
pulsar-common/src/main/proto/PulsarApi.proto changed 2.7% diff
pulsar-functions/proto/src/main/proto/Function.proto changed 6.5% diff

YAML Files (125 of 183):

NameStatusDeltaVisual Diff
conf/functions_worker.yml changed 7.6% diff
deployment/kubernetes/aws/bookkeeper.yaml removed
deployment/kubernetes/aws/broker.yaml removed
deployment/kubernetes/aws/cluster-metadata.yaml removed
deployment/kubernetes/aws/monitoring.yaml removed
deployment/kubernetes/aws/proxy.yaml removed
deployment/kubernetes/aws/zookeeper.yaml removed
deployment/kubernetes/generic/k8s-1-9-and-above/admin.yaml removed
deployment/kubernetes/generic/k8s-1-9-and-above/bookie.yaml removed
deployment/kubernetes/generic/k8s-1-9-and-above/broker.yaml removed
deployment/kubernetes/generic/k8s-1-9-and-above/cluster-metadata.yaml removed
deployment/kubernetes/generic/k8s-1-9-and-above/monitoring.yaml removed
deployment/kubernetes/generic/k8s-1-9-and-above/proxy.yaml removed
deployment/kubernetes/generic/k8s-1-9-and-above/zookeeper.yaml removed
deployment/kubernetes/generic/original/admin.yaml removed
deployment/kubernetes/generic/original/bookie.yaml removed
deployment/kubernetes/generic/original/broker.yaml removed
deployment/kubernetes/generic/original/cluster-metadata.yaml removed
deployment/kubernetes/generic/original/monitoring.yaml removed
deployment/kubernetes/generic/original/proxy.yaml removed
deployment/kubernetes/generic/original/zookeeper.yaml removed
deployment/kubernetes/google-kubernetes-engine/bookie.yaml removed
deployment/kubernetes/google-kubernetes-engine/broker.yaml removed
deployment/kubernetes/google-kubernetes-engine/cluster-metadata.yaml removed
deployment/kubernetes/google-kubernetes-engine/monitoring.yaml removed
deployment/kubernetes/google-kubernetes-engine/proxy.yaml removed
deployment/kubernetes/google-kubernetes-engine/zookeeper.yaml removed
deployment/kubernetes/helm/examples/values-cs.yaml added
deployment/kubernetes/helm/examples/values-jwt-asymmetric.yaml added
deployment/kubernetes/helm/examples/values-jwt-symmetric.yaml added
deployment/kubernetes/helm/examples/values-local-cluster.yaml added
deployment/kubernetes/helm/examples/values-local-pv.yaml added
deployment/kubernetes/helm/examples/values-minikube.yaml added
deployment/kubernetes/helm/examples/values-no-persistence.yaml added
deployment/kubernetes/helm/examples/values-one-node.yaml added
deployment/kubernetes/helm/examples/values-pulsar.yaml added
deployment/kubernetes/helm/examples/values-tls.yaml added
deployment/kubernetes/helm/pulsar/Chart.yaml changed 21.9% diff
deployment/kubernetes/helm/pulsar/templates/autorecovery-configmap.yaml changed 46.5% diff
deployment/kubernetes/helm/pulsar/templates/autorecovery-deployment.yaml renamed 77.5% diff
deployment/kubernetes/helm/pulsar/templates/autorecovery-statefulset.yaml
deployment/kubernetes/helm/pulsar/templates/autorecovery-service.yaml added
deployment/kubernetes/helm/pulsar/templates/bastion-configmap.yaml removed
deployment/kubernetes/helm/pulsar/templates/bastion-deployment.yaml removed
deployment/kubernetes/helm/pulsar/templates/bookkeeper-cluster-initialize.yaml added
deployment/kubernetes/helm/pulsar/templates/bookkeeper-configmap.yaml changed 35.3% diff
deployment/kubernetes/helm/pulsar/templates/bookkeeper-pdb.yaml changed 18.9% diff
deployment/kubernetes/helm/pulsar/templates/bookkeeper-service.yaml changed 22.5% diff
deployment/kubernetes/helm/pulsar/templates/bookkeeper-statefulset.yaml changed 60.0% diff
deployment/kubernetes/helm/pulsar/templates/bookkeeper-storageclass.yaml changed 24.7% diff
deployment/kubernetes/helm/pulsar/templates/broker-cluster-role-binding.yaml added
deployment/kubernetes/helm/pulsar/templates/broker-configmap.yaml changed 100.0% diff
deployment/kubernetes/helm/pulsar/templates/broker-deployment.yaml renamed 83.6% diff
deployment/kubernetes/helm/pulsar/templates/broker-service-account.yaml
deployment/kubernetes/helm/pulsar/templates/broker-pdb.yaml changed 19.2% diff
deployment/kubernetes/helm/pulsar/templates/broker-rbac.yaml added
deployment/kubernetes/helm/pulsar/templates/broker-service.yaml changed 38.1% diff
deployment/kubernetes/helm/pulsar/templates/broker-statefulset.yaml added
deployment/kubernetes/helm/pulsar/templates/function-worker-configmap.yaml added
deployment/kubernetes/helm/pulsar/templates/grafana-deployment.yaml changed 47.5% diff
deployment/kubernetes/helm/pulsar/templates/grafana-ingress.yaml added
deployment/kubernetes/helm/pulsar/templates/grafana-service.yaml changed 29.4% diff
deployment/kubernetes/helm/pulsar/templates/keytool.yaml added
deployment/kubernetes/helm/pulsar/templates/prometheus-configmap.yaml changed 9.5% diff
deployment/kubernetes/helm/pulsar/templates/prometheus-deployment.yaml changed 21.0% diff
deployment/kubernetes/helm/pulsar/templates/prometheus-pvc.yaml changed 29.7% diff
deployment/kubernetes/helm/pulsar/templates/prometheus-rbac.yaml changed 7.6% diff
deployment/kubernetes/helm/pulsar/templates/prometheus-service.yaml changed 20.0% diff
deployment/kubernetes/helm/pulsar/templates/prometheus-storageclass.yaml changed 16.7% diff
deployment/kubernetes/helm/pulsar/templates/proxy-configmap.yaml changed 100.0% diff
deployment/kubernetes/helm/pulsar/templates/proxy-deployment.yaml removed
deployment/kubernetes/helm/pulsar/templates/proxy-pdb.yaml changed 20.8% diff
deployment/kubernetes/helm/pulsar/templates/proxy-service.yaml changed 46.6% diff
deployment/kubernetes/helm/pulsar/templates/proxy-statefulset.yaml added
deployment/kubernetes/helm/pulsar/templates/pulsar-cluster-initialize.yaml added
deployment/kubernetes/helm/pulsar/templates/pulsar-manager-admin-secret.yaml changed 5.0% diff
deployment/kubernetes/helm/pulsar/templates/pulsar-manager-configmap.yaml added
deployment/kubernetes/helm/pulsar/templates/pulsar-manager-deployment.yaml changed 31.7% diff
deployment/kubernetes/helm/pulsar/templates/pulsar-manager-service.yaml changed 19.2% diff
deployment/kubernetes/helm/pulsar/templates/tls-cert-internal-issuer.yaml added
deployment/kubernetes/helm/pulsar/templates/tls-certs-internal.yaml added
deployment/kubernetes/helm/pulsar/templates/toolset-configmap.yaml added
deployment/kubernetes/helm/pulsar/templates/toolset-service.yaml added
deployment/kubernetes/helm/pulsar/templates/toolset-statefulset.yaml added
deployment/kubernetes/helm/pulsar/templates/zookeeper-configmap.yaml changed 47.9% diff
deployment/kubernetes/helm/pulsar/templates/zookeeper-metadata.yaml removed
deployment/kubernetes/helm/pulsar/templates/zookeeper-pdb.yaml changed 19.0% diff
deployment/kubernetes/helm/pulsar/templates/zookeeper-service.yaml changed 40.7% diff
deployment/kubernetes/helm/pulsar/templates/zookeeper-statefulset.yaml changed 73.2% diff
deployment/kubernetes/helm/pulsar/templates/zookeeper-storageclass.yaml changed 29.7% diff
deployment/kubernetes/helm/pulsar/values-mini.yaml removed
deployment/kubernetes/helm/pulsar/values.yaml changed 100.0% diff
pulsar-function-go/conf/conf.yaml changed 1.9% diff
pulsar-function-go/golangci.yml added
pulsar-io/aerospike/src/main/resources/META-INF/services/pulsar-io.yaml changed 7.6% diff
pulsar-io/batch-data-generator/src/main/resources/META-INF/services/pulsar-io.yaml added
pulsar-io/canal/src/main/resources/META-INF/services/pulsar-io.yaml changed 7.1% diff
pulsar-io/cassandra/src/main/resources/META-INF/services/pulsar-io.yaml changed 7.6% diff
pulsar-io/dynamodb/src/main/resources/META-INF/services/pulsar-io.yaml added
pulsar-io/dynamodb/src/test/resources/sourceConfig.yaml added
pulsar-io/elastic-search/src/main/resources/META-INF/services/pulsar-io.yaml changed 7.9% diff
pulsar-io/elastic-search/src/test/resources/sinkConfig.yaml changed 2.6% diff
pulsar-io/file/src/main/resources/META-INF/services/pulsar-io.yaml changed 7.0% diff
pulsar-io/flume/src/main/resources/META-INF/services/pulsar-io.yaml changed 6.0% diff
pulsar-io/hbase/src/main/resources/META-INF/services/pulsar-io.yaml changed 7.3% diff
pulsar-io/hdfs2/src/main/resources/META-INF/services/pulsar-io.yaml changed 7.2% diff
pulsar-io/hdfs3/src/main/resources/META-INF/services/pulsar-io.yaml changed 7.2% diff
pulsar-io/influxdb/src/main/resources/META-INF/services/pulsar-io.yaml changed 7.6% diff
pulsar-io/influxdb/src/test/resources/sinkConfig-v2.yaml added
pulsar-io/influxdb/src/test/resources/sinkConfig.yaml renamed 0.0%
pulsar-io/influxdb/src/test/resources/sinkConfig-v1.yaml
pulsar-io/jdbc/clickhouse/src/main/resources/META-INF/services/pulsar-io.yaml added
pulsar-io/jdbc/mariadb/src/main/resources/META-INF/services/pulsar-io.yaml added
pulsar-io/jdbc/postgres/src/main/resources/META-INF/services/pulsar-io.yaml added
pulsar-io/jdbc/sqlite/src/main/resources/META-INF/services/pulsar-io.yaml added
pulsar-io/jdbc/src/main/resources/META-INF/services/pulsar-io.yaml removed
pulsar-io/kafka/src/main/resources/META-INF/services/pulsar-io.yaml changed 13.1% diff
pulsar-io/kinesis/src/main/resources/META-INF/services/pulsar-io.yaml changed 14.1% diff
pulsar-io/mongo/src/main/resources/META-INF/services/pulsar-io.yaml changed 12.5% diff
pulsar-io/netty/src/main/resources/META-INF/services/pulsar-io.yaml changed 7.2% diff
pulsar-io/rabbitmq/src/main/resources/META-INF/services/pulsar-io.yaml changed 14.2% diff
pulsar-io/rabbitmq/src/test/resources/sinkConfig.yaml changed 4.9% diff
pulsar-io/redis/src/main/resources/META-INF/services/pulsar-io.yaml changed 7.4% diff
pulsar-io/solr/src/main/resources/META-INF/services/pulsar-io.yaml changed 6.5% diff
pulsar-io/twitter/src/main/resources/META-INF/services/pulsar-io.yaml changed 7.8% diff

Directories (199 of 2056):

NameStatus
deployment/kubernetes/aws removed
deployment/kubernetes/generic removed
deployment/kubernetes/generic/k8s-1-9-and-above removed
deployment/kubernetes/generic/original removed
deployment/kubernetes/google-kubernetes-engine removed
deployment/kubernetes/helm/examples added
deployment/kubernetes/helm/hack added
deployment/kubernetes/helm/scripts added
deployment/kubernetes/helm/scripts/cert-manager added
deployment/kubernetes/helm/scripts/pulsar added
jclouds-shaded renamed
kafka-connect-avro-converter-shaded
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/validator added
pulsar-broker-common/src/test/java/org/apache/pulsar/broker/validator added
pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept added
pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic added
pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept added
pulsar-broker/src/test/java/org/apache/pulsar/broker/systopic added
pulsar-client-cpp/docker/alpine added
pulsar-client-cpp/pkg/apk added
pulsar-common/src/main/java/io added
pulsar-common/src/main/java/io/airlift added
pulsar-common/src/main/java/io/airlift/compress added
pulsar-common/src/main/java/io/airlift/compress/zstd added
pulsar-common/src/main/java/org/apache/pulsar/common/events added
pulsar-common/src/main/java/org/apache/pulsar/common/schema added
pulsar-common/src/main/java/org/apache/pulsar/common/validator added
pulsar-common/src/test/java/org/apache/pulsar/common/validator added
pulsar-function-go/examples/consumer added
pulsar-function-go/examples/contextFunc added
pulsar-function-go/examples/exclamationFunc added
pulsar-function-go/examples/hello added
pulsar-function-go/examples/inputFunc added
pulsar-function-go/examples/logFunc added
pulsar-function-go/examples/outputFunc added
pulsar-function-go/examples/producer added
pulsar-function-go/examples/test removed
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/functions added
pulsar-io/aws added
pulsar-io/aws/src added
pulsar-io/aws/src/main added
pulsar-io/aws/src/main/java added
pulsar-io/aws/src/main/java/org added
pulsar-io/aws/src/main/java/org/apache added
pulsar-io/aws/src/main/java/org/apache/pulsar added
pulsar-io/aws/src/main/java/org/apache/pulsar/io added
pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws added
pulsar-io/batch added
pulsar-io/batch-data-generator added
pulsar-io/batch-data-generator/src added
pulsar-io/batch-data-generator/src/main added
pulsar-io/batch-data-generator/src/main/java added
pulsar-io/batch-data-generator/src/main/java/org added
pulsar-io/batch-data-generator/src/main/java/org/apache added
pulsar-io/batch-data-generator/src/main/java/org/apache/pulsar added
pulsar-io/batch-data-generator/src/main/java/org/apache/pulsar/io added
pulsar-io/batch-data-generator/src/main/java/org/apache/pulsar/io/batchdatagenerator added
pulsar-io/batch-data-generator/src/main/resources added
pulsar-io/batch-data-generator/src/main/resources/META-INF added
pulsar-io/batch-data-generator/src/main/resources/META-INF/services added
pulsar-io/batch-data-generator/src/test added
pulsar-io/batch-data-generator/src/test/java added
pulsar-io/batch-data-generator/src/test/java/org added
pulsar-io/batch-data-generator/src/test/java/org/apache added
pulsar-io/batch-data-generator/src/test/java/org/apache/pulsar added
pulsar-io/batch-data-generator/src/test/java/org/apache/pulsar/io added
pulsar-io/batch-data-generator/src/test/java/org/apache/pulsar/io/batchdatagenerator added
pulsar-io/batch-discovery-triggerers added
pulsar-io/batch-discovery-triggerers/src added
pulsar-io/batch-discovery-triggerers/src/main added
pulsar-io/batch-discovery-triggerers/src/main/java added
pulsar-io/batch-discovery-triggerers/src/main/java/org added
pulsar-io/batch-discovery-triggerers/src/main/java/org/apache added
pulsar-io/batch-discovery-triggerers/src/main/java/org/apache/pulsar added
pulsar-io/batch-discovery-triggerers/src/main/java/org/apache/pulsar/io added
pulsar-io/batch-discovery-triggerers/src/main/java/org/apache/pulsar/io/batchdiscovery added
pulsar-io/batch/src added
pulsar-io/batch/src/main added
pulsar-io/batch/src/main/java added
pulsar-io/batch/src/main/java/org added
pulsar-io/batch/src/main/java/org/apache added
pulsar-io/batch/src/main/java/org/apache/pulsar added
pulsar-io/batch/src/main/java/org/apache/pulsar/io added
pulsar-io/batch/src/main/java/org/apache/pulsar/io/batch added
pulsar-io/batch/src/test added
pulsar-io/batch/src/test/java added
pulsar-io/batch/src/test/java/org added
pulsar-io/batch/src/test/java/org/apache added
pulsar-io/batch/src/test/java/org/apache/pulsar added
pulsar-io/batch/src/test/java/org/apache/pulsar/io added
pulsar-io/batch/src/test/java/org/apache/pulsar/io/batch added
pulsar-io/dynamodb added
pulsar-io/dynamodb/src added
pulsar-io/dynamodb/src/main added
pulsar-io/dynamodb/src/main/java added
pulsar-io/dynamodb/src/main/java/org added
pulsar-io/dynamodb/src/main/java/org/apache added
pulsar-io/dynamodb/src/main/java/org/apache/pulsar added
pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io added
pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb added
pulsar-io/dynamodb/src/main/resources added
pulsar-io/dynamodb/src/main/resources/META-INF added
pulsar-io/dynamodb/src/main/resources/META-INF/services added
pulsar-io/dynamodb/src/test added
pulsar-io/dynamodb/src/test/java added
pulsar-io/dynamodb/src/test/java/org added
pulsar-io/dynamodb/src/test/java/org/apache added
pulsar-io/dynamodb/src/test/java/org/apache/pulsar added
pulsar-io/dynamodb/src/test/java/org/apache/pulsar/io added
pulsar-io/dynamodb/src/test/java/org/apache/pulsar/io/dynamodb added
pulsar-io/dynamodb/src/test/resources added
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1 added
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2 added
pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/v1 added
pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/v2 added
pulsar-io/jdbc/clickhouse added
pulsar-io/jdbc/clickhouse/src added
pulsar-io/jdbc/clickhouse/src/main added
pulsar-io/jdbc/clickhouse/src/main/java added
pulsar-io/jdbc/clickhouse/src/main/java/org added
pulsar-io/jdbc/clickhouse/src/main/java/org/apache added
pulsar-io/jdbc/clickhouse/src/main/java/org/apache/pulsar added
pulsar-io/jdbc/clickhouse/src/main/java/org/apache/pulsar/io added
pulsar-io/jdbc/clickhouse/src/main/java/org/apache/pulsar/io/jdbc added
pulsar-io/jdbc/clickhouse/src/main/resources added
pulsar-io/jdbc/clickhouse/src/main/resources/META-INF added
pulsar-io/jdbc/clickhouse/src/main/resources/META-INF/services added
pulsar-io/jdbc/core added
pulsar-io/jdbc/core/src added
pulsar-io/jdbc/core/src/main added
pulsar-io/jdbc/core/src/main/java added
pulsar-io/jdbc/core/src/main/java/org added
pulsar-io/jdbc/core/src/main/java/org/apache added
pulsar-io/jdbc/core/src/main/java/org/apache/pulsar added
pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io added
pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc added
pulsar-io/jdbc/mariadb added
pulsar-io/jdbc/mariadb/src added
pulsar-io/jdbc/mariadb/src/main added
pulsar-io/jdbc/mariadb/src/main/java added
pulsar-io/jdbc/mariadb/src/main/java/org added
pulsar-io/jdbc/mariadb/src/main/java/org/apache added
pulsar-io/jdbc/mariadb/src/main/java/org/apache/pulsar added
pulsar-io/jdbc/mariadb/src/main/java/org/apache/pulsar/io added
pulsar-io/jdbc/mariadb/src/main/java/org/apache/pulsar/io/jdbc added
pulsar-io/jdbc/mariadb/src/main/resources added
pulsar-io/jdbc/mariadb/src/main/resources/META-INF added
pulsar-io/jdbc/mariadb/src/main/resources/META-INF/services added
pulsar-io/jdbc/postgres added
pulsar-io/jdbc/postgres/src added
pulsar-io/jdbc/postgres/src/main added
pulsar-io/jdbc/postgres/src/main/java added
pulsar-io/jdbc/postgres/src/main/java/org added
pulsar-io/jdbc/postgres/src/main/java/org/apache added
pulsar-io/jdbc/postgres/src/main/java/org/apache/pulsar added
pulsar-io/jdbc/postgres/src/main/java/org/apache/pulsar/io added
pulsar-io/jdbc/postgres/src/main/java/org/apache/pulsar/io/jdbc added
pulsar-io/jdbc/postgres/src/main/resources added
pulsar-io/jdbc/postgres/src/main/resources/META-INF added
pulsar-io/jdbc/postgres/src/main/resources/META-INF/services added
pulsar-io/jdbc/sqlite added
pulsar-io/jdbc/sqlite/src added
pulsar-io/jdbc/sqlite/src/main added
pulsar-io/jdbc/sqlite/src/main/java added
pulsar-io/jdbc/sqlite/src/main/java/org added
pulsar-io/jdbc/sqlite/src/main/java/org/apache added
pulsar-io/jdbc/sqlite/src/main/java/org/apache/pulsar added
pulsar-io/jdbc/sqlite/src/main/java/org/apache/pulsar/io added
pulsar-io/jdbc/sqlite/src/main/java/org/apache/pulsar/io/jdbc added
pulsar-io/jdbc/sqlite/src/main/resources added
pulsar-io/jdbc/sqlite/src/main/resources/META-INF added
pulsar-io/jdbc/sqlite/src/main/resources/META-INF/services added
pulsar-io/jdbc/sqlite/src/test added
pulsar-io/jdbc/sqlite/src/test/java added
pulsar-io/jdbc/sqlite/src/test/java/org added
pulsar-io/jdbc/sqlite/src/test/java/org/apache added
pulsar-io/jdbc/sqlite/src/test/java/org/apache/pulsar added
pulsar-io/jdbc/sqlite/src/test/java/org/apache/pulsar/io added
pulsar-io/jdbc/sqlite/src/test/java/org/apache/pulsar/io/jdbc added
pulsar-io/jdbc/src removed
pulsar-io/jdbc/src/main removed
pulsar-io/jdbc/src/main/java removed
pulsar-io/jdbc/src/main/java/org removed
pulsar-io/jdbc/src/main/java/org/apache removed
pulsar-io/jdbc/src/main/java/org/apache/pulsar removed
pulsar-io/jdbc/src/main/java/org/apache/pulsar/io removed
pulsar-io/jdbc/src/main/java/org/apache/pulsar/io/jdbc removed
pulsar-io/jdbc/src/main/resources removed
pulsar-io/jdbc/src/main/resources/META-INF removed
pulsar-io/jdbc/src/main/resources/META-INF/services removed
pulsar-io/jdbc/src/test removed
pulsar-io/jdbc/src/test/java removed
pulsar-io/jdbc/src/test/java/org removed
pulsar-io/jdbc/src/test/java/org/apache removed
pulsar-io/jdbc/src/test/java/org/apache/pulsar removed
pulsar-io/jdbc/src/test/java/org/apache/pulsar/io removed
pulsar-io/jdbc/src/test/java/org/apache/pulsar/io/jdbc removed
pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema added
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/stats added

Archives (1 of 5):

NameStatusDeltaVisual Diff
pulsar-broker/src/test/resources/pulsar-functions-api-examples.jar changed 1.1%

Information Files (1 of 2):

NameStatusDeltaVisual Diff
pulsar-client-cpp/pkg/apk/APKBUILD added

Licenses (3 of 36):

NameStatusDeltaVisual Diff
distribution/server/licenses/LICENSE-zstd-jni.txt removed
distribution/server/src/assemble/LICENSE.bin.txt changed 2.1% diff
pulsar-sql/presto-distribution/LICENSE changed 1.7% diff

Readme Files (4 of 19):

NameStatusDeltaVisual Diff
deployment/kubernetes/aws/README.md moved 26.2% diff
pulsar-flink/README.md
deployment/kubernetes/helm/README.md changed 65.3% diff
README.md changed 17.3% diff

Text Files (17 of 51):

NameStatusDeltaVisual Diff
dashboard/Dockerfile changed 3.3% diff
deployment/kubernetes/helm/pulsar/templates/_autorecovery.tpl added
deployment/kubernetes/helm/pulsar/templates/_bookkeeper.tpl added
deployment/kubernetes/helm/pulsar/templates/_broker.tpl added
deployment/kubernetes/helm/pulsar/templates/_helpers.tpl changed 67.7% diff
deployment/kubernetes/helm/pulsar/templates/_toolset.tpl added
deployment/kubernetes/helm/pulsar/templates/_zookeeper.tpl added
distribution/server/src/assemble/NOTICE.bin.txt changed 2.4% diff
docker/pulsar-standalone/Dockerfile changed 24.6% diff
docker/pulsar/Dockerfile changed 5.8% diff
pulsar-client-cpp/docker/alpine/Dockerfile added
pulsar-client-cpp/docker/alpine/Dockerfile-alpine-3.8 added
pulsar-client-go/go.mod changed 2.0% diff
pulsar-function-go/examples/go.mod added
pulsar-function-go/examples/go.sum added
pulsar-function-go/go.mod changed 100.0% diff
pulsar-function-go/go.sum changed 100.0% diff

Packages Compared:

apache-pulsar-2.5.2-src.tar.gz
apache-pulsar-2.6.0-src.tar.gz


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