"Fossies" - the Fresh Open Source Software Archive  

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

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

Summary:

The "apache-pulsar" source code changed by about 16.9% and now consists of 3245 regular files (+176), 1 symbolic link and 1810 directories (+113).

Related Informations:

None found by Fossies.

Changes In Files (According File Type):

File TypeTotalAddedRemovedChanged
Header file 139 1 1 15
C program 9 0 0 0
C++ program 138 1 0 21
Spec file 1 0 0 0
Go program 52 0 0 5
Java program 2258 229 46 656
Python program 78 2 18 9
Shell program 61 1 3 15
Ruby program 1 0 0 0
CMake file 7 0 0 3
Configuration file 45 0 3 16
Initialization file 5 0 1 0
JavaScript file 1 0 0 0
JSON file 14 0 0 0
Man page 5 0 0 0
SGML document 6 0 5 0
Symbolic link 1 0 0 0
XML document 174 17 5 120
Certificate file 64 0 0 0
Command file 1 0 0 0
CSS style sheet 1 0 0 1
Doxygen file 1 0 0 0
HTML page 23 0 10 1
Property file 10 0 0 1
Protocol Buffer file 11 0 0 3
YAML file 135 22 7 22
Directory 1843 146 33 0
Archive 5 0 0 1
Information file 1 0 0 0
License 34 2 0 2
Readme file 18 0 0 6
Text file 47 1 1 6
Total Files5189422133903



Header Files (17 of 139):

NameStatusDeltaVisual Diff
pulsar-client-cpp/generated/lib/PulsarApi.pb.h removed
pulsar-client-cpp/include/pulsar/c/message.h changed 1.2% diff
pulsar-client-cpp/include/pulsar/Consumer.h changed 4.8% diff
pulsar-client-cpp/include/pulsar/Message.h changed 3.6% diff
pulsar-client-cpp/include/pulsar/MessageBatch.h added
pulsar-client-cpp/include/pulsar/MessageId.h changed 4.0% diff
pulsar-client-cpp/include/pulsar/Reader.h changed 48.7% diff
pulsar-client-cpp/include/pulsar/Result.h changed 9.2% diff
pulsar-client-cpp/include/pulsar/Schema.h changed 0.6% diff
pulsar-client-cpp/lib/Commands.h changed 5.6% diff
pulsar-client-cpp/lib/ConsumerImpl.h changed 3.8% diff
pulsar-client-cpp/lib/ConsumerImplBase.h changed 3.1% diff
pulsar-client-cpp/lib/MessageImpl.h changed 4.2% diff
pulsar-client-cpp/lib/MultiTopicsConsumerImpl.h changed 1.1% diff
pulsar-client-cpp/lib/PartitionedConsumerImpl.h changed 1.5% diff
pulsar-client-cpp/lib/ReaderImpl.h changed 6.2% diff
pulsar-client-cpp/python/src/utils.h changed 2.5% diff

C++ Programs (22 of 138):

NameStatusDeltaVisual Diff
pulsar-client-cpp/lib/c/c_Message.cc changed 2.7% diff
pulsar-client-cpp/lib/ClientConnection.cc changed 0.3% diff
pulsar-client-cpp/lib/ClientImpl.cc changed 0.1% diff
pulsar-client-cpp/lib/Commands.cc changed 8.8% diff
pulsar-client-cpp/lib/Consumer.cc changed 7.8% diff
pulsar-client-cpp/lib/ConsumerImpl.cc changed 4.5% diff
pulsar-client-cpp/lib/Message.cc changed 4.5% diff
pulsar-client-cpp/lib/MessageBatch.cc added
pulsar-client-cpp/lib/MessageImpl.cc changed 7.8% diff
pulsar-client-cpp/lib/MultiTopicsConsumerImpl.cc changed 0.5% diff
pulsar-client-cpp/lib/PartitionedConsumerImpl.cc changed 0.7% diff
pulsar-client-cpp/lib/ProducerImpl.cc changed 0.7% diff
pulsar-client-cpp/lib/Reader.cc changed 36.4% diff
pulsar-client-cpp/lib/ReaderImpl.cc changed 5.6% diff
pulsar-client-cpp/lib/Result.cc changed 8.1% diff
pulsar-client-cpp/python/src/consumer.cc changed 6.3% diff
pulsar-client-cpp/python/src/message.cc changed 19.3% diff
pulsar-client-cpp/python/src/reader.cc changed 17.8% diff
pulsar-client-cpp/tests/BasicEndToEndTest.cc changed 1.7% diff
pulsar-client-cpp/tests/BatchMessageTest.cc changed 4.4% diff
pulsar-client-cpp/tests/ConsumerStatsTest.cc changed 10.0% diff
pulsar-client-cpp/tests/SchemaTest.cc changed 3.1% diff

Go Programs (5 of 52):

NameStatusDeltaVisual Diff
pulsar-client-go/pulsar/c_client.go changed 0.6% diff
pulsar-client-go/pulsar/c_consumer.go changed 0.9% diff
pulsar-client-go/pulsar/c_producer.go changed 0.7% diff
pulsar-client-go/pulsar/c_reader.go changed 0.6% diff
pulsar-function-go/pf/instance.go changed 3.7% diff

Java Programs (931 of 2258):

NameStatusDeltaVisual Diff
buildtools/src/main/java/org/apache/pulsar/tests/PulsarTestListener.java changed 29.7% diff
examples/spark/src/main/java/org/apache/spark/streaming/receiver/example/ProducerSparkReceiverData.
java
changed 7.2% diff
examples/spark/src/main/java/org/apache/spark/streaming/receiver/example/ProducerSparkWithPojo.java added
examples/spark/src/main/java/org/apache/spark/streaming/receiver/example/SensorReading.java added
examples/spark/src/main/java/org/apache/spark/streaming/receiver/example/SparkStreamingPulsarReceiv
erExample.java
changed 3.2% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/AsyncCallbacks.java changed 3.4% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryCacheImpl.java changed 7.0% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryCacheManager.java changed 18.6% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java changed 1.3% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryImpl.java changed 3.1% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java changed 1.2% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerOfflineBacklog.java changed 0.6% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpFindNewest.java changed 3.1% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java changed 3.9% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ReadOnlyManagedLedgerImpl.java changed 1.3% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerException.java changed 2.3% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/offload/OffloadUtils.java changed 8.0% diff
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/Errors.java added
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/EntryCacheManagerTest.java changed 13.5% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/EntryCacheTest.java changed 0.5% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedCursorContainerTest.java changed 0.3% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedCursorTest.java changed 0.1% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerBkTest.java changed 0.6% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryChangeLedgerPat
hTest.java
added
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryTest.java changed 10.2% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/OffloadPrefixReadTest.java changed 0.7% diff
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/offload/OffloadUtilsTest.java added
managed-ledger/src/test/java/org/apache/bookkeeper/test/BookKeeperClusterTestCase.java changed 11.2% diff
managed-ledger/src/test/java/org/apache/bookkeeper/test/MockedBookKeeperTestCase.java changed 11.0% diff
managed-ledger/src/test/java/org/apache/bookkeeper/test/PortManager.java removed
managed-ledger/src/test/java/org/apache/bookkeeper/test/ZooKeeperUtil.java changed 32.6% diff
pulsar-broker-auth-athenz/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProvi
derAthenzTest.java
changed 12.0% diff
pulsar-broker-auth-sasl/src/test/java/org/apache/pulsar/broker/authentication/ProxySaslAuthenticati
onTest.java
changed 5.5% diff
pulsar-broker-auth-sasl/src/test/java/org/apache/pulsar/broker/authentication/SaslAuthenticateTest.
java
changed 0.7% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderTl
s.java
changed 3.6% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvid
er.java
changed 2.6% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/cache/ConfigurationCacheService.java changed 0.7% diff
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java changed 10.5% diff
pulsar-broker-common/src/test/java/org/apache/pulsar/common/configuration/PulsarConfigurationLoader
Test.java
changed 1.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java changed 22.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/ClustersBase.java changed 1.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/FunctionsBase.java changed 36.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java changed 4.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java changed 15.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinksBase.java changed 35.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourcesBase.java changed 31.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java changed 2.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java changed 0.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java changed 7.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/NonPersistentTopics.java changed 32.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java changed 0.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/SchemasResource.java changed 10.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java changed 15.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/cache/LocalZooKeeperCacheService.java changed 1.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/BrokerHostUsage.java changed 11.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/GenericBrokerHostUsageImpl.ja
va
changed 22.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java changed 8.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LoadManagerShared.java changed 1.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java changed 4.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/OverloadShedder.java changed 6.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/SimpleLoadManagerImpl.java changed 0.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/LoadManager.java changed 4.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/NoopLoadManager.java changed 3.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceBundleOwnershipListener.jav
a
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java changed 17.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnershipCache.java changed 5.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/NoOpShutdownService.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/package-info.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandler.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlerDefinition.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlerDefinitions.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlerMetadata.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlers.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlerUtils.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlerWithClassLoader.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java changed 11.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractBaseDispatcher.java changed 1.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractDispatcherMultipleConsumers.ja
va
changed 2.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractDispatcherSingleActiveConsumer
.java
changed 4.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java changed 100.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java changed 1.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java changed 22.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerServiceException.java changed 9.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java changed 4.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Dispatcher.java changed 7.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeAutoSplitStickyKeyConsumerSel
ector.java
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeStickyKeyConsumerSelector.jav
a
renamed 71.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeExclusiveStickyKeyConsumerSelector.java
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/InMemoryRedeliveryTracker.java changed 18.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcher.
java
changed 11.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherM
ultipleConsumers.java
changed 2.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherS
ingleActiveConsumer.java
changed 0.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentStickyKeyDi
spatcherMultipleConsumers.java
changed 12.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscriptio
n.java
changed 13.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java changed 9.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiter.java changed 11.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java changed 3.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipl
eConsumers.java
changed 2.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleA
ctiveConsumer.java
changed 0.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMoni
tor.java
changed 16.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageFinder.jav
a
changed 5.1% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java changed 0.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatch
erMultipleConsumers.java
changed 63.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java changed 6.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java changed 6.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/SubscribeRateLimiter.java changed 5.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java changed 24.1% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiter.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarChannelInitializer.java changed 24.1% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/RedeliveryTracker.java changed 7.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/RedeliveryTrackerDisabled.java changed 11.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/AvroSchemaBasedCompatibilityChe
ck.java
changed 22.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorage.java changed 15.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/DefaultSchemaRegistryService.ja
va
changed 40.1% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/exceptions/IncompatibleSchemaEx
ception.java
changed 6.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/exceptions/SchemaException.java changed 5.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/JsonSchemaCompatibilityCheck.ja
va
changed 23.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/KeyValueSchemaCompatibilityChec
k.java
changed 34.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaCompatibilityCheck.java changed 58.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaCompatibilityStrategy.jav
a
moved 17.5% diff
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/SchemaCompatibilityStrategy.java
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistry.java changed 19.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryService.java changed 3.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java changed 48.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaStorage.java changed 7.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/validator/SchemaRegistryService
WithSchemaDataValidator.java
changed 30.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java changed 17.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/StickyKeyConsumerSelector.java changed 13.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Subscription.java changed 7.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Topic.java changed 18.1% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/metrics/AbstractMetrics.java changed 1.3% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/NamespaceStats.java changed 3.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/AggregatedNamespaceStats.java changed 2.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/DataSketchesSummaryLo
gger.java
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/Summary.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/NamespaceStatsAggregator.java changed 3.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/PrometheusMetricsGenerator.ja
va
changed 5.1% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TopicStats.java changed 2.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/tools/BrokerTool.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/tools/LoadReportCommand.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/tools/package-info.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/NoTxnsCommittedA
tLedgerException.java
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/PersistentTransactionB
uffer.java
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/PersistentTransactionB
ufferReader.java
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TransactionCursorImpl.
java
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TransactionMetaImpl.ja
va
added
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionCursor.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionMeta.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/TransactionMetadataStoreService.java added
pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java changed 2.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/web/RestException.java changed 3.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/web/WebService.java changed 20.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java changed 2.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/common/naming/NamespaceBundleFactory.java changed 2.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorTool.java changed 9.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/PulsarBrokerStarter.java changed 4.0% diff
pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataSetup.java changed 45.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java changed 3.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandaloneStarter.java changed 3.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/PulsarTransactionCoordinatorMetadataSetup.java added
pulsar-broker/src/main/java/org/apache/pulsar/utils/CmdUtility.java changed 3.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/utils/CopyOnWriteArrayList.java removed
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiOffloadTest.java changed 2.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaAutoUpdateTest.java changed 1.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java changed 7.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaValidationEnforced.java changed 1.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java changed 4.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest2.java changed 4.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTlsAuthTest.java changed 1.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminTest.java changed 2.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/BrokerAdminClientTlsAuthTest.java changed 9.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/IncrementPartitionsTest.java changed 3.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java changed 5.8% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/PersistentTopicsTest.java changed 60.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v1/V1_AdminApiTest.java changed 3.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v1/V1_AdminApiTest2.java changed 4.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java changed 11.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/BookKeeperClientFactoryImplTest.java changed 10.7% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/cache/ResourceQuotaCacheTest.java changed 7.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/AntiAffinityNamespaceGroupTest.jav
a
changed 12.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/impl/OverloadShedderTest.java changed 7.8% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/LoadBalancerTest.java changed 2.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/ModularLoadManagerImplTest.java changed 9.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/SimpleLoadManagerImplTest.java changed 7.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/namespace/NamespaceCreateBundlesTest.java changed 5.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/namespace/NamespaceOwnershipListenerTests.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/namespace/NamespaceServiceTest.java changed 0.8% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/namespace/OwnershipCacheTest.java changed 5.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/protocol/MockProtocolHandler.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/protocol/ProtocolHandlersTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/protocol/ProtocolHandlerUtilsTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/protocol/ProtocolHandlerWithClassLoaderTest.ja
va
added
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/AdvertisedAddressTest.java changed 31.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java changed 3.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BatchMessageTest.java changed 7.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BkEnsemblesTestBase.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerBkEnsemblesTests.java changed 22.7% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerBookieIsolationTest.java changed 7.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceAutoTopicCreationTest.jav
a
changed 1.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceTest.java changed 6.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceThrottlingTest.java changed 8.7% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/HashRangeAutoSplitStickyKeyConsumerSel
ectorTest.java
added
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/HashRangeExclusiveStickyKeyConsumerSel
ectorTest.java
added
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/HashRangeStickyKeyConsumerSelectorTest
.java
removed
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/MaxMessageSizeTest.java changed 13.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PeerReplicatorTest.java changed 1.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/MessageDuplicationTest.java changed 10.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentSubscriptionTest.
java
changed 3.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentDispatcherFailoverConsumerTe
st.java
changed 4.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentFailoverE2ETest.java changed 4.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentMessageFinderTest.java changed 45.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentQueueE2ETest.java changed 0.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentTopicConcurrentTest.java changed 2.8% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentTopicTest.java changed 9.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/RackAwareTest.java changed 6.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorRateLimiterTest.java changed 2.8% 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 17.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/BaseAvroSchemaCompatibilityTest
.java
changed 0.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/ClientGetSchemaTest.java changed 3.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/JsonSchemaCompatibilityCheckTes
t.java
changed 1.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/KeyValueSchemaCompatibilityChec
kTest.java
changed 0.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/PartitionedTopicsSchemaTest.jav
a
changed 28.7% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/SchemaServiceTest.java changed 0.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/validator/SchemaRegistryService
WithSchemaDataValidatorTest.java
changed 1.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ServerCnxTest.java changed 5.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TopicOwnerTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TransactionMetadataStoreServiceTest.ja
va
added
pulsar-broker/src/test/java/org/apache/pulsar/broker/SLAMonitoringTest.java changed 17.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/PrometheusMetricsTest.java changed 8.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/buffer/PersistentTransactionBuffer
Test.java
added
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionCoordinator
ClientTest.java
added
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionMetaStoreAs
signmentTest.java
added
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionMetaStoreTe
stBase.java
added
pulsar-broker/src/test/java/org/apache/pulsar/broker/web/WebServiceTest.java changed 10.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/zookeeper/ClusterMetadataSetupTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/broker/zookeeper/ZooKeeperClientAspectJTest.java changed 6.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/AuthenticatedProducerConsumerTest.java changed 5.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/AuthenticationTlsHostnameVerificationTest.
java
changed 5.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/AuthorizationProducerConsumerTest.java changed 3.7% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/BrokerServiceLookupTest.java changed 7.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientDeduplicationFailureTest.java changed 10.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientDeduplicationTest.java changed 80.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientErrorsTest.java changed 11.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerBatchReceiveTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerRedeliveryTest.java changed 5.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/DeadLetterTopicTest.java changed 1.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/DispatcherBlockConsumerTest.java changed 6.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ExposeMessageRedeliveryCountTest.java changed 56.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/InterceptorsTest.java changed 20.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java changed 55.8% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/MessageDispatchThrottlingTest.java changed 8.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/MockBrokerService.java changed 11.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/MutualAuthenticationTest.java changed 2.7% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/NonPersistentKeySharedSubscriptionTest.jav
a
changed 57.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/NonPersistentTopicTest.java changed 5.7% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ProducerConsumerBase.java changed 4.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ProducerCreationTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ServiceUrlProviderTest.java changed 4.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java changed 2.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleSchemaTest.java changed 76.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleTypedProducerConsumerTest.java changed 0.7% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/TlsHostVerification.java changed 5.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/TlsProducerConsumerBase.java changed 12.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/TlsProducerConsumerTest.java changed 8.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/TopicReaderTest.java changed 4.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerBase.java changed 4.7% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java changed 1.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BrokerClientIntegrationTest.java changed 4.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ConnectionPoolTest.java changed 8.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ConsumerConfigurationTest.java changed 3.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ConsumerUnsubscribeTest.java changed 25.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageParserTest.java changed 2.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessagePublishThrottlingTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PatternTopicsConsumerImplTest.java changed 5.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ProducerSemaphoreTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PulsarMultiHostClientTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/RawReaderTest.java changed 0.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ReaderTest.java changed 100.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/SchemaDeleteTest.java changed 2.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/SequenceIdWithErrorTest.java changed 3.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TopicFromMessageTest.java changed 13.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TopicPublishThrottlingInitTest.java added
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TopicsConsumerImplTest.java changed 4.8% diff
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/UnAcknowledgedMessagesTimeoutTest.java changed 20.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/compaction/CompactedTopicTest.java changed 1.8% diff
pulsar-broker/src/test/java/org/apache/pulsar/compaction/CompactionTest.java changed 0.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/compaction/CompactorTest.java changed 0.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/discovery/service/web/DiscoveryServiceWebTest.java changed 5.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionE2ESecurityTest.java changed 8.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionLocalRunTest.java changed 18.8% diff
pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionPublishTest.java changed 15.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionStateTest.java removed
pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarWorkerAssignmentTest.java changed 10.5% diff
pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionAdminTest.java changed 16.6% diff
pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionE2ETest.java changed 4.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionTlsTest.java changed 10.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/schema/compatibility/SchemaCompatibilityCheckTest.jav
a
added
pulsar-broker/src/test/java/org/apache/pulsar/schema/compatibility/Schemas.java added
pulsar-broker/src/test/java/org/apache/pulsar/utils/SimpleTextOutputStreamTest.java changed 3.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/utils/StatsOutputStreamTest.java changed 38.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/websocket/proxy/ProxyAuthenticationTest.java changed 9.3% diff
pulsar-broker/src/test/java/org/apache/pulsar/websocket/proxy/ProxyAuthorizationTest.java changed 4.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/websocket/proxy/ProxyConfigurationTest.java changed 4.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/websocket/proxy/ProxyPublishConsumeTest.java changed 9.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/websocket/proxy/ProxyPublishConsumeTlsTest.java changed 9.2% diff
pulsar-broker/src/test/java/org/apache/pulsar/websocket/proxy/ProxyPublishConsumeWithoutZKTest.java changed 7.4% diff
pulsar-broker/src/test/java/org/apache/pulsar/websocket/proxy/v1/V1_ProxyAuthenticationTest.java changed 7.8% diff
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/MessageListener.j
ava
changed 5.0% diff
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/ProducerConfigura
tion.java
changed 3.2% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/NamespacesImpl.java changed 7.5% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SchemasImpl.java changed 4.7% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SinksImpl.java changed 2.5% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SourcesImpl.java changed 2.5% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java changed 1.3% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Namespaces.java changed 7.0% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Sinks.java changed 2.1% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Sources.java changed 2.1% diff
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Topics.java changed 2.8% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Authentication.java changed 5.3% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/AuthenticationDataProvider.java changed 7.5% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/AuthenticationFactory.java changed 5.5% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/BatcherBuilder.java changed 16.9% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/BatchMessageContainer.java changed 9.9% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/BatchReceivePolicy.java added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ClientBuilder.java changed 16.9% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/CompressionType.java changed 18.4% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Consumer.java changed 37.6% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java changed 32.3% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerCryptoFailureAction.java changed 23.6% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerInterceptor.java changed 8.7% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerStats.java changed 14.0% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/CryptoKeyReader.java changed 10.9% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/EncodedAuthenticationParameterSupport.
java
changed 5.9% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/HashingScheme.java changed 4.2% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/interceptor/package-info.java added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/interceptor/ProducerInterceptor.java added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/interceptor/ProducerInterceptorWrapper
.java
added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/KeySharedMode.java added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/KeySharedPolicy.java added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Message.java changed 17.5% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/MessageId.java changed 36.1% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/MessageListener.java changed 26.3% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/MessageRoutingMode.java changed 50.2% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Messages.java added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/package-info.java added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Producer.java changed 31.3% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java changed 42.9% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerCryptoFailureAction.java changed 19.1% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerInterceptor.java changed 14.9% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerStats.java changed 3.7% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClient.java changed 21.6% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java changed 100.0% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Range.java added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Reader.java changed 24.1% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ReaderBuilder.java changed 27.3% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ReaderListener.java changed 21.5% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/RegexSubscriptionMode.java changed 12.5% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Schema.java changed 13.3% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/FieldSchemaBuilder.java changed 12.3% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/package-info.java added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaDefinition.java changed 27.4% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaDefinitionBuilder.java changed 10.1% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaInfoProvider.java changed 2.3% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaReader.java changed 62.5% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaWriter.java changed 3.8% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/SchemaSerializationException.java changed 58.3% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ServiceUrlProvider.java changed 24.2% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/SubscriptionInitialPosition.java changed 17.1% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/SubscriptionType.java changed 36.1% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/transaction/package-info.java added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/transaction/Transaction.java added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/transaction/TransactionBuilder.java added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/transaction/TransactionCoordinatorClie
nt.java
added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/transaction/TransactionCoordinatorClie
ntException.java
added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/TypedMessageBuilder.java changed 36.3% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/DefaultImplementation.java changed 15.2% diff
pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/package-info.java added
pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/ReflectionUtils.java changed 2.2% diff
pulsar-client-api/src/main/java/org/apache/pulsar/common/api/AuthData.java changed 14.7% diff
pulsar-client-api/src/main/java/org/apache/pulsar/common/api/EncryptionContext.java changed 6.9% diff
pulsar-client-api/src/main/java/org/apache/pulsar/common/api/package-info.java added
pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/KeyValue.java changed 0.8% diff
pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/KeyValueEncodingType.java changed 21.0% diff
pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/package-info.java added
pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/SchemaInfo.java changed 9.1% diff
pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/SchemaInfoWithVersion.java changed 6.1% diff
pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/SchemaType.java changed 7.9% diff
pulsar-client-kafka-compat/pulsar-client-kafka-tests/src/test/java/org/apache/pulsar/client/kafka/c
ompat/examples/ProducerAvroExample.java
changed 1.0% diff
pulsar-client-kafka-compat/pulsar-client-kafka-tests/src/test/java/org/apache/pulsar/client/kafka/c
ompat/examples/ProducerExample.java
changed 1.3% diff
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src/test/java/org/apache/pulsar/client/kaf
ka/compat/examples/HighLevelConsumerExample.java
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src/test/java/org/apache/pulsar/client/kaf
ka/compat/examples/LowLevelConsumerExample.java
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src/test/java/org/apache/pulsar/client/kaf
ka/compat/examples/ProducerExample.java
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src/test/java/org/apache/pulsar/client/kaf
ka/compat/examples/utils/Tweet.java
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java/org/apache/pulsar/client/kaf
ka/compat/examples/ConsumerAvroExample.java
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java/org/apache/pulsar/client/kaf
ka/compat/examples/ConsumerExample.java
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java/org/apache/pulsar/client/kaf
ka/compat/examples/ProducerAvroExample.java
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java/org/apache/pulsar/client/kaf
ka/compat/examples/ProducerExample.java
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java/org/apache/pulsar/client/kaf
ka/compat/examples/utils/Bar.java
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java/org/apache/pulsar/client/kaf
ka/compat/examples/utils/Foo.java
added
pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/Puls
arKafkaConsumer.java
changed 7.5% diff
pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/producer/Puls
arKafkaProducer.java
changed 8.4% diff
pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/pulsar/client/kafka/compat/
KafkaProducerInterceptorWrapper.java
changed 1.5% diff
pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/pulsar/client/kafka/compat/
MessageIdUtils.java
moved 2.8% diff
pulsar-client/src/main/java/org/apache/pulsar/client/util/MessageIdUtils.java
pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/pulsar/client/kafka/compat/
PulsarClientKafkaConfig.java
changed 5.5% diff
pulsar-client-kafka-compat/pulsar-client-kafka/src/test/java/org/apache/kafka/clients/producer/Puls
arKafkaProducerTest.java
changed 4.2% diff
pulsar-client-kafka-compat/pulsar-client-kafka/src/test/java/org/apache/pulsar/client/kafka/compat/
KafkaProducerInterceptorWrapperTest.java
changed 8.5% diff
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/consumer/
ConsumerConnector.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/consumer/
ConsumerIterator.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/consumer/
PulsarConsumerConfig.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/consumer/
PulsarKafkaConsumer.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/consumer/
PulsarKafkaStream.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/consumer/
PulsarMessageAndMetadata.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/producer/
PulsarClientKafkaConfig.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/producer/
PulsarKafkaProducer.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarByteBufferMessageSet.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarFetchResponse.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarKafkaSimpleConsumer.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarMessage.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarMsgAndOffset.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarOffsetCommitRequest.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarOffsetCommitResponse.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarOffsetFetchRequest.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarOffsetFetchResponse.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarOffsetMetadataAndError.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarOffsetRequest.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarOffsetResponse.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarPartitionMetadata.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarTopicMetadata.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer/PulsarTopicMetadataResponse.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java/org/apache/kafka/clients/consumer/
PulsarKafkaConsumerTest.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java/org/apache/kafka/clients/producer/
PulsarKafkaProducerTest.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java/org/apache/pulsar/client/kafka/tes
t/KafkaProducerConsumerTest.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java/org/apache/pulsar/client/kafka/tes
t/KafkaProducerSimpleConsumerTest.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/kafka/clients/consumer/
PulsarKafkaConsumer.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/kafka/clients/producer/
PulsarKafkaProducer.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/pulsar/client/kafka/com
pat/KafkaMessageRouter.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/pulsar/client/kafka/com
pat/PulsarClientKafkaConfig.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/pulsar/client/kafka/com
pat/PulsarConsumerKafkaConfig.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/pulsar/client/kafka/com
pat/PulsarKafkaSchema.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/pulsar/client/kafka/com
pat/PulsarProducerKafkaConfig.java
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/test/java/org/apache/kafka/clients/producer/
PulsarKafkaProducerTest.java
added
pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/CmdFunctionsTest.java changed 6.7% diff
pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/PulsarAdminToolTest.java changed 0.9% diff
pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/utils/IOUtilsTest.java changed 2.7% diff
pulsar-client-tools-test/src/test/java/org/apache/pulsar/client/cli/PulsarClientToolTest.java changed 7.0% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CliCommand.java changed 3.8% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdBase.java changed 14.7% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java changed 10.7% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctionWorker.java changed 5.0% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdGenerateDocument.java added
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java changed 11.8% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSchemas.java changed 25.6% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java changed 2.3% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java changed 2.6% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/PulsarAdminTool.java changed 1.2% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/utils/SchemaExtractor.java changed 38.2% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java changed 6.8% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java changed 11.1% diff
pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/NoSplitter.java added
pulsar-client/src/main/java/org/apache/pulsar/client/impl/AbstractBatchMessageContainer.java changed 22.6% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerBase.java changed 19.8% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java changed 22.5% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageKeyBasedContainer.java changed 10.1% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/BinaryProtoLookupService.java changed 3.8% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java changed 10.9% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ConsumerConfigurationData.java changed 5.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ProducerConfigurationData.java changed 72.9% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ReaderConfigurationData.java changed 7.9% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionHandler.java changed 6.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionPool.java changed 2.0% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java changed 82.6% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java changed 12.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java changed 16.3% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsDisabled.java changed 9.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorder.java changed 3.3% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java changed 14.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/HandlerState.java changed 16.5% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/HttpClient.java changed 2.2% 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/MessageImpl.java changed 3.3% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessagesImpl.java added
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java changed 15.8% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/Murmur3_32Hash.java changed 2.0% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedProducerImpl.java changed 1.9% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PatternMultiTopicsConsumerImpl.java changed 4.3% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBase.java changed 42.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java changed 17.7% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java changed 31.5% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerInterceptors.java changed 23.0% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java changed 0.6% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java changed 12.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderBuilderImpl.java changed 12.1% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java changed 6.0% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/RoundRobinPartitionMessageRouterImpl.java changed 15.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AbstractSchema.java added
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AutoConsumeSchema.java changed 35.6% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AutoProduceBytesSchema.java changed 22.8% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/BooleanSchema.java changed 27.3% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/ByteBufferSchema.java changed 33.5% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/ByteBufSchema.java changed 27.5% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/ByteSchema.java changed 38.1% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/BytesSchema.java changed 41.1% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/DateSchema.java changed 31.1% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/DoubleSchema.java changed 37.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/FloatSchema.java changed 39.7% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericAvroReader.java changed 35.9% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericJsonReader.java changed 39.5% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/IntSchema.java changed 39.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/LongSchema.java changed 37.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/reader/AvroReader.java changed 55.9% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/reader/JsonReader.java changed 48.3% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/reader/ProtobufReader.java changed 50.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/ShortSchema.java changed 40.8% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/StringSchema.java changed 23.8% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/StructSchema.java changed 15.7% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/TimeSchema.java changed 31.5% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/TimestampSchema.java changed 32.4% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicMessageIdImpl.java changed 3.8% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/package-info.java added
pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionBufferClient.java added
pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionBufferClientImpl.j
ava
added
pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionBuilderImpl.java added
pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionCoordinatorClientI
mpl.java
added
pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionImpl.java added
pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java added
pulsar-client/src/main/java/org/apache/pulsar/client/impl/TypedMessageBuilderImpl.java changed 21.2% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/UnAckedMessageTracker.java changed 7.8% diff
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ZeroQueueConsumerImpl.java changed 12.9% diff
pulsar-client/src/test/java/org/apache/pulsar/client/api/KeySharedPolicyTest.java added
pulsar-client/src/test/java/org/apache/pulsar/client/api/RangeTest.java added
pulsar-client/src/test/java/org/apache/pulsar/client/examples/TransactionExample.java added
pulsar-client/src/test/java/org/apache/pulsar/client/impl/ClientCnxTest.java changed 61.0% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/ConnectionTimeoutTest.java changed 20.6% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/ConsumerBuilderImplTest.java changed 5.6% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/ConsumerImplTest.java changed 3.3% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImplTest.java changed 2.2% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/ProducerBuilderImplTest.java changed 7.7% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImplTest.java added
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/AvroSchemaTest.java changed 6.9% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/BooleanSchemaTest.java changed 26.4% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/BytesSchemaTest.java changed 19.5% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/DateSchemaTest.java changed 28.5% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/DoubleSchemaTest.java changed 25.4% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/FloatSchemaTest.java changed 28.7% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/IntSchemaTest.java changed 29.8% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/JSONSchemaTest.java changed 6.2% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/LongSchemaTest.java changed 27.1% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/PrimitiveSchemaTest.java changed 19.0% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/ProtobufSchemaTest.java changed 14.2% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/ShortSchemaTest.java changed 31.4% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/StringSchemaTest.java changed 18.3% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/TimeSchemaTest.java changed 17.9% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/TimestampSchemaTest.java changed 17.8% diff
pulsar-client/src/test/java/org/apache/pulsar/client/impl/UnAckedMessageTrackerTest.java added
pulsar-common/src/main/java/org/apache/pulsar/common/api/proto/PulsarApi.java changed 45.9% diff
pulsar-common/src/main/java/org/apache/pulsar/common/api/proto/PulsarMarkers.java changed 12.7% diff
pulsar-common/src/main/java/org/apache/pulsar/common/functions/FunctionConfig.java changed 6.8% diff
pulsar-common/src/main/java/org/apache/pulsar/common/io/SinkConfig.java changed 8.5% diff
pulsar-common/src/main/java/org/apache/pulsar/common/io/SourceConfig.java changed 10.9% diff
pulsar-common/src/main/java/org/apache/pulsar/common/naming/NamespaceName.java changed 1.3% diff
pulsar-common/src/main/java/org/apache/pulsar/common/naming/TopicName.java changed 1.5% diff
pulsar-common/src/main/java/org/apache/pulsar/common/nar/NarClassLoader.java changed 1.3% diff
pulsar-common/src/main/java/org/apache/pulsar/common/net/ServiceURI.java changed 7.4% diff
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/BrokerNamespaceIsolationData.jav
a
changed 16.3% diff
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/DispatchRate.java changed 15.5% diff
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/Policies.java changed 13.8% diff
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PublishRate.java added
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/SubscriptionStats.java changed 3.2% diff
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicStats.java changed 4.5% diff
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java changed 44.2% diff
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Markers.java changed 30.9% diff
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarDecoder.java changed 37.4% diff
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/schema/SchemaHash.java added
pulsar-common/src/main/java/org/apache/pulsar/common/util/RateLimiter.java changed 8.0% diff
pulsar-common/src/main/java/org/apache/pulsar/common/util/SslContextAutoRefreshBuilder.java changed 1.1% diff
pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/LoadReport.java changed 3.4% diff
pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/LocalBrokerData.java changed 4.1% diff
pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/ServiceLookupData.java changed 45.1% diff
pulsar-common/src/test/java/org/apache/pulsar/common/net/ServiceURITest.java changed 10.8% diff
pulsar-common/src/test/java/org/apache/pulsar/common/protocol/MarkersTest.java changed 29.2% diff
pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentSortedLongPairSetTe
st.java
changed 0.9% diff
pulsar-common/src/test/java/org/apache/pulsar/common/util/RateLimiterTest.java changed 12.2% diff
pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/DiscoveryService.java changed 11.9% diff
pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/server/ServerManager.jav
a
changed 16.3% diff
pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/web/DiscoveryServiceServ
let.java
changed 2.6% diff
pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/web/ZookeeperCacheLoader
.java
changed 2.9% diff
pulsar-discovery-service/src/test/java/org/apache/pulsar/discovery/service/BaseDiscoveryTestSetup.j
ava
changed 11.5% diff
pulsar-discovery-service/src/test/java/org/apache/pulsar/discovery/service/server/DiscoveryServiceW
ebTest.java
changed 6.8% diff
pulsar-discovery-service/src/test/java/org/apache/pulsar/discovery/service/web/DiscoveryServiceWebT
est.java
changed 8.4% diff
pulsar-flink/src/main/java/org/apache/flink/batch/connectors/pulsar/BasePulsarOutputFormat.java changed 12.3% diff
pulsar-flink/src/main/java/org/apache/flink/batch/connectors/pulsar/package-info.java added
pulsar-flink/src/main/java/org/apache/flink/batch/connectors/pulsar/PulsarAvroOutputFormat.java changed 7.6% diff
pulsar-flink/src/main/java/org/apache/flink/batch/connectors/pulsar/PulsarCsvOutputFormat.java changed 7.5% diff
pulsar-flink/src/main/java/org/apache/flink/batch/connectors/pulsar/PulsarJsonOutputFormat.java changed 7.8% diff
pulsar-flink/src/main/java/org/apache/flink/batch/connectors/pulsar/PulsarOutputFormat.java changed 7.1% diff
pulsar-flink/src/main/java/org/apache/flink/batch/connectors/pulsar/serialization/AvroSerialization
Schema.java
changed 4.7% diff
pulsar-flink/src/main/java/org/apache/flink/batch/connectors/pulsar/serialization/CsvSerializationS
chema.java
changed 6.2% diff
pulsar-flink/src/main/java/org/apache/flink/batch/connectors/pulsar/serialization/package-info.java added
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/CachedPulsarClient.java added
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarProducer.java changed 7.2% diff
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/package-info.java added
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/partitioner/package-info.ja
va
added
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/partitioner/PulsarKeyExtrac
tor.java
changed 7.6% diff
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSource.java changed 10.5% diff
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarSourceBuilder.java changed 11.5% diff
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarTableSink.java changed 3.9% diff
pulsar-flink/src/test/java/org/apache/flink/streaming/connectors/pulsar/CachedPulsarClientTest.java added
pulsar-flink/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSourceTests.j
ava
changed 3.9% diff
pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Context.java changed 4.4% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java changed 2.3% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.j
ava
changed 0.1% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/LogAppender.java changed 6.0% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/StateContext.jav
a
changed 8.2% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/StateContextImpl
.java
changed 25.9% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/FunctionStatsMan
ager.java
changed 1.3% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/SinkStatsManager
.java
changed 1.7% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/SourceStatsManag
er.java
changed 1.7% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/TopicSchema.java changed 0.8% diff
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFunctionExecuto
r.java
changed 0.5% diff
pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/instance/ContextImplTest.java changed 8.2% diff
pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/instance/state/StateContextImpl
Test.java
changed 14.5% diff
pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java changed 1.2% diff
pulsar-functions/runtime-all/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceMain.ja
va
changed 1.2% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/ClearTextFunctionTokenAuthP
rovider.java
changed 16.9% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/FunctionAuthProvider.java changed 30.4% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesFunctionAuthProvi
der.java
changed 66.2% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesSecretsTokenAuthP
rovider.java
changed 19.5% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/NoOpFunctionAuthProvider.ja
va
removed
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/JavaInstanceStarter.java changed 8.9% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/BasicKubernet
esManifestCustomizer.java
added
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesMan
ifestCustomizer.java
added
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRun
timeFactoryConfig.java
added
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/KubernetesRuntime.java moved 11.0% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRuntime.java
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/KubernetesRuntimeFactory
.java
moved 72.9% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRuntimeFactory.java
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/process/ProcessRuntimeFa
ctoryConfig.java
added
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/ProcessRuntime.java moved 1.0% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/process/ProcessRuntime.java
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/ProcessRuntimeFactory.ja
va
moved 59.8% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/process/ProcessRuntimeFactory.java
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeCustomizer.java added
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeFactory.java changed 51.3% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeUtils.java changed 1.7% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntimeFact
oryConfig.java
added
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/ThreadRuntime.java moved 2.1% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntime.java
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/ThreadRuntimeFactory.jav
a
moved 45.6% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntimeFactory.java
pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/auth/ClearTextFunctionTokenAuthP
roviderTest.java
changed 13.3% diff
pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/auth/KubernetesSecretsTokenAuthP
roviderTest.java
changed 64.8% diff
pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRun
timeFactoryTest.java
added
pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRun
timeTest.java
added
pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/runtime/KubernetesRuntimeFactory
Test.java
removed
pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/runtime/KubernetesRuntimeTest.ja
va
removed
pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/runtime/ProcessRuntimeTest.java moved 10.2% diff
pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/runtime/process/ProcessRuntimeTest.java
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionCommon.java changed 2.8% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java changed 1.9% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/Reflections.java changed 5.3% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java changed 3.1% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfigUtils.java changed 5.6% diff
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/ValidatorUtils.java changed 2.7% diff
pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/ReflectionsTest.java changed 1.6% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/ConnectorsManager.java changed 13.3% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionActioner.java changed 5.0% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.jav
a
changed 9.3% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionsStatsGenerator.ja
va
changed 2.7% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.jav
a
changed 0.8% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.jav
a
changed 10.8% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SinksImpl.java changed 9.6% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SourcesImpl.java changed 9.4% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/WorkerServer.java changed 12.2% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/Worker.java changed 2.4% diff
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java moved 29.0% diff
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerService.java changed 0.7% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/FunctionActionerTest.java changed 13.9% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/FunctionRuntimeManagerTest
.java
changed 29.5% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/MembershipManagerTest.java changed 5.3% diff
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/SchedulerManagerTest.java changed 1.2% diff
pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeSinkConfig.java changed 3.2% diff
pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalSourceConfig.java changed 2.0% diff
pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra/CassandraSinkConfig.java changed 2.6% diff
pulsar-io/core/src/main/java/org/apache/pulsar/io/core/annotations/FieldDoc.java changed 4.8% diff
pulsar-io/core/src/main/java/org/apache/pulsar/io/core/KeyValue.java changed 2.3% diff
pulsar-io/core/src/main/java/org/apache/pulsar/io/core/PushSource.java changed 11.8% diff
pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java changed 16.4% diff
pulsar-io/core/src/main/java/org/apache/pulsar/io/core/SinkContext.java changed 4.9% diff
pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Source.java changed 8.0% diff
pulsar-io/core/src/main/java/org/apache/pulsar/io/core/SourceContext.java changed 21.1% diff
pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistory.java changed 2.3% diff
pulsar-io/debezium/core/src/test/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistoryTest.java changed 3.0% diff
pulsar-io/debezium/mongodb/src/main/java/org/apache/pulsar/io/debezium/mongodb/DebeziumMongoDbSourc
e.java
added
pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchConfig.java changed 3.8% diff
pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileSourceConfig.java changed 2.4% diff
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/AbstractFileTests.java changed 9.6% diff
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/FileConsumerThreadTests.java changed 2.1% diff
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/FileListingThreadTests.java changed 7.6% diff
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/ProcessedFileThreadTests.java changed 4.3% diff
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/FlumeConfig.java changed 2.6% diff
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/PropertiesFileConfigurationProvider.j
ava
changed 0.7% diff
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/node/TestAbstractZooKeeperConfigurationPro
vider.java
changed 6.3% diff
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/sink/StringSinkTests.java changed 10.6% diff
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/source/StringSourceTests.java changed 13.1% diff
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/HbaseAbstractConfig.java changed 5.6% diff
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java changed 3.3% diff
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseGenericRecordSink.java changed 15.6% diff
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseSinkConfig.java changed 3.0% diff
pulsar-io/hbase/src/test/java/org/apache/pulsar/io/hbase/sink/HbaseGenericRecordSinkTest.java changed 1.4% diff
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConfig.java changed 5.8% diff
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConnector.java changed 0.8% diff
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsSinkConfig.java changed 2.7% diff
pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConfig.java changed 5.8% diff
pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConnector.java changed 0.8% diff
pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsSinkConfig.java changed 2.7% diff
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBSinkConfig.java changed 3.6% diff
pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/InfluxDBGenericRecordSinkTest.java changed 0.7% diff
pulsar-io/jdbc/src/main/java/org/apache/pulsar/io/jdbc/JdbcSinkConfig.java changed 2.0% diff
pulsar-io/jdbc/src/main/java/org/apache/pulsar/io/jdbc/JdbcUtils.java changed 1.6% diff
pulsar-io/jdbc/src/test/java/org/apache/pulsar/io/jdbc/JdbcSinkTest.java changed 1.4% diff
pulsar-io/jdbc/src/test/java/org/apache/pulsar/io/jdbc/SqliteUtils.java changed 2.2% diff
pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSource
.java
changed 6.7% diff
pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarIOSourceTask
Context.java
changed 30.3% diff
pulsar-io/kafka-connect-adaptor/src/test/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSource
Test.java
changed 2.7% diff
pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSinkConfig.java changed 1.7% diff
pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java changed 1.4% diff
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/AbstractKinesisConnector.java added
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/AwsCredentialProviderPlugin.java changed 69.6% diff
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/AwsDefaultProviderChainPlugin.java added
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/BaseKinesisConfig.java added
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecord.java added
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecordProcessor.java added
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecordProcessorFactory.java added
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSink.java changed 23.7% diff
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSinkConfig.java changed 24.8% diff
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSource.java added
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSourceConfig.java added
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/STSAssumeRoleProviderPlugin.java added
pulsar-io/kinesis/src/test/java/org/apache/pulsar/io/kinesis/KinesisSinkConfigTests.java added
pulsar-io/kinesis/src/test/java/org/apache/pulsar/io/kinesis/KinesisSinkTest.java changed 10.0% diff
pulsar-io/kinesis/src/test/java/org/apache/pulsar/io/kinesis/KinesisSourceConfigTests.java added
pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoConfig.java changed 30.0% diff
pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoSink.java changed 46.5% diff
pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoSource.java added
pulsar-io/mongo/src/test/java/org/apache/pulsar/io/mongodb/MongoConfigTest.java changed 3.3% diff
pulsar-io/mongo/src/test/java/org/apache/pulsar/io/mongodb/MongoSinkTest.java changed 24.7% diff
pulsar-io/mongo/src/test/java/org/apache/pulsar/io/mongodb/MongoSourceTest.java added
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/NettySourceConfig.java changed 5.4% diff
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server/NettyChannelInitializer.java removed
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server/NettyServer.java changed 11.4% diff
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server/NettyServerHandler.java removed
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/NettyTCPChannelInitializer.java added
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/NettyTCPServerHandler.java added
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/package-info.java added
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp/NettyUDPChannelInitializer.java added
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp/NettyUDPServerHandler.java added
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp/package-info.java added
pulsar-io/netty/src/main/java/package-info.java added
pulsar-io/netty/src/test/java/org/apache/pulsar/io/netty/server/NettyChannelInitializerTest.java removed
pulsar-io/netty/src/test/java/org/apache/pulsar/io/netty/tcp/NettyTCPChannelInitializerTest.java added
pulsar-io/netty/src/test/java/org/apache/pulsar/io/netty/udp/NettyUDPChannelInitializerTest.java added
pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQAbstractConfig.java changed 3.2% diff
pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSinkConfig.java changed 3.9% diff
pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSourceConfig.java changed 3.8% diff
pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/RedisAbstractConfig.java changed 3.8% diff
pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/sink/RedisSinkConfig.java changed 3.3% diff
pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr/SolrSinkConfig.java changed 4.1% diff
pulsar-io/solr/src/test/java/org/apache/pulsar/io/solr/SolrGenericRecordSinkTest.java changed 2.5% diff
pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHoseConfig.java changed 2.5% diff
pulsar-log4j2-appender/src/main/java/org/apache/pulsar/log4j2/appender/PulsarManager.java changed 3.1% diff
pulsar-log4j2-appender/src/test/java/org/apache/pulsar/log4j2/appender/builder/ConfigurationAssembl
erTest.java
changed 5.7% diff
pulsar-log4j2-appender/src/test/java/org/apache/pulsar/log4j2/appender/builder/ConfigurationBuilder
Test.java
changed 0.8% diff
pulsar-log4j2-appender/src/test/java/org/apache/pulsar/log4j2/appender/builder/CustomConfigurationF
actory.java
changed 2.5% diff
pulsar-log4j2-appender/src/test/java/org/apache/pulsar/log4j2/appender/PulsarAppenderTest.java changed 5.6% diff
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/GetResult.java added
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataStore.java added
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataStoreConfig.java added
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataStoreException.java added
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataStoreFactory.java added
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/Stat.java added
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/zookeeper/ZKMetadataStore.java added
pulsar-metadata/src/test/java/org/apache/pulsar/metadata/MetadataStoreTest.java added
pulsar-metadata/src/test/java/org/apache/pulsar/metadata/TestZKServer.java added
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/AdminProxyHandler.java changed 0.8% diff
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java changed 21.4% diff
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/WebServer.java changed 8.0% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/AuthedAdminProxyHandlerTest.java changed 8.9% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyAuthenticatedProducerConsumerTest.ja
va
changed 8.2% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyAuthenticationTest.java changed 6.7% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyConnectionThrottlingTest.java changed 20.7% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyForwardAuthDataTest.java changed 19.5% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyLookupThrottlingTest.java changed 17.9% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyParserTest.java changed 12.0% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyRolesEnforcementTest.java changed 8.5% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyTest.java changed 8.7% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyTlsTest.java changed 11.7% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyWithAuthorizationNegTest.java changed 7.7% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyWithAuthorizationTest.java changed 9.4% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyWithoutServiceDiscoveryTest.java changed 10.0% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/SuperUserAuthedAdminProxyHandlerTest.java changed 10.8% diff
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/UnauthedAdminProxyHandlerTest.java changed 7.7% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java changed 14.3% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorConfig.java changed 24.3% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorUtils.java changed 1.7% diff
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java changed 0.01% diff
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarConnectorConfig.java changed 43.0% diff
pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java changed 7.9% diff
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions/EndOfTransa
ctionException.java
moved 5.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/EndOfTransactionException.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions/package-inf
o.java
moved 7.1% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/package-info.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions/Transaction
BufferException.java
moved 4.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/TransactionBufferException.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions/Transaction
NotFoundException.java
moved 5.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/TransactionNotFoundException.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions/Transaction
NotSealedException.java
moved 5.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/TransactionNotSealedException.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions/Transaction
SealedException.java
moved 5.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/TransactionSealedException.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions/UnexpectedT
xnStatusException.java
moved 4.2% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/UnexpectedTxnStatusException.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/impl/InMemTransactionB
uffer.java
moved 21.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/InMemTransactionBuffer.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/impl/InMemTransactionB
ufferProvider.java
moved 15.1% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/InMemTransactionBufferProvider.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/impl/InMemTransactionB
ufferReader.java
moved 15.9% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/InMemTransactionBufferReader.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/impl/package-info.java moved 6.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/package-info.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/impl/TransactionEntryI
mpl.java
moved 10.4% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TransactionEntryImpl.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/package-info.java moved 6.1% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/package-info.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/TransactionBuffer.java moved 15.6% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionBuffer.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/TransactionBufferProvi
der.java
moved 2.5% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionBufferProvider.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/TransactionBufferReade
r.java
moved 7.7% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionBufferReader.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/TransactionEntry.java moved 2.8% diff
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionEntry.java
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/TransactionMeta.java removed
pulsar-transaction/buffer/src/test/java/org/apache/pulsar/transaction/buffer/impl/InMemTransactionB
ufferReaderTest.java
moved 3.9% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/buffer/InMemTransactionBufferReaderTest.java
pulsar-transaction/buffer/src/test/java/org/apache/pulsar/transaction/buffer/impl/TransactionBuffer
Test.java
moved 6.0% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/buffer/TransactionBufferTest.java
pulsar-transaction/buffer/src/test/java/org/apache/pulsar/transaction/buffer/impl/TransactionEntryI
mplTest.java
moved 8.1% diff
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/buffer/TransactionEntryImplTest.java
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/exceptions/C
oordinatorException.java
changed 100.0% diff
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/exceptions/I
nvalidTxnStatusException.java
removed
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/exceptions/T
ransactionNotFoundException.java
removed
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/InMemTr
ansactionMetadataStore.java
changed 8.4% diff
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/InMemTr
ansactionMetadataStoreProvider.java
changed 14.5% diff
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/TxnMeta
Impl.java
changed 4.8% diff
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/TransactionC
oordinatorID.java
changed 9.9% diff
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/TransactionM
etadataStore.java
changed 2.9% diff
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/TransactionM
etadataStoreProvider.java
changed 6.8% diff
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/TxnMeta.java changed 3.3% diff
pulsar-transaction/coordinator/src/test/java/org/apache/pulsar/transaction/coordinator/TransactionM
etadataStoreProviderTest.java
changed 2.9% diff
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/AbstractWebSocketHandler.java changed 2.6% diff
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ProducerHandler.java changed 2.1% diff
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/service/ProxyServer.java changed 11.7% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/stats/CacheMetricsCollector.java added
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/GlobalZooKeeperCache.java changed 1.2% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsemble.java changed 4.4% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/LocalZooKeeperCache.java changed 2.8% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/LocalZooKeeperConnectionService.ja
va
changed 1.8% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/SerializeUtilsAspect.java removed
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZkBookieRackAffinityMapping.java changed 6.5% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementP
olicy.java
changed 1.5% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZooKeeperCache.java changed 5.2% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZookeeperClientFactoryImpl.java changed 3.5% diff
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZooKeeperSessionWatcher.java changed 7.8% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/DeserializersTest.java changed 8.8% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsembleTest.java changed 54.8% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/LocalZooKeeperConnectionServiceTes
t.java
changed 7.1% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/MockedZooKeeperClientFactoryImpl.j
ava
changed 18.0% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/ZkBookieRackAffinityMappingTest.ja
va
changed 9.3% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementP
olicyTest.java
changed 4.9% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/ZookeeperBkClientFactoryImplTest.j
ava
changed 14.6% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/ZookeeperClientFactoryImplTest.jav
a
changed 11.8% diff
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/ZookeeperServerTest.java changed 13.2% diff
tests/bc_2_0_0/src/test/java/org/apache/pulsar/tests/integration/SmokeTest.java changed 1.6% diff
tests/bc_2_0_1/src/test/java/org/apache/pulsar/tests/integration/SmokeTest.java changed 1.6% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/PulsarSt
andaloneTestSuite2_3.java
added
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/PulsarSt
andaloneTestSuite2_4.java
added
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/SmokeTes
t2_2.java
changed 20.7% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/SmokeTes
t2_3.java
added
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/SmokeTes
t2_4.java
added
tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/CLITest.java changed 7.6% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/HealthcheckTest.java renamed 8.2% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/HealthCheckTest.java
tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/DebeziumMongoDbConta
iner.java
added
tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/DebeziumPostgreSqlCo
ntainer.java
added
tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/PulsarContainer.java changed 2.9% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.j
ava
changed 18.8% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTestBa
se.java
changed 6.7% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/DebeziumMongoDbSourceTester.
java
added
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/DebeziumMySqlSourceTester.ja
va
changed 39.6% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/DebeziumPostgreSqlSourceTest
er.java
added
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/KafkaSourceTester.java changed 7.6% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/SourceTester.java changed 100.0% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/messaging/MessagingBase.java changed 25.8% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/messaging/NonPersistentTopicMes
sagingTest.java
changed 5.4% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/messaging/TopicMessagingBase.ja
va
changed 22.1% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/offload/TestBaseOffload.java added
tests/integration/src/test/java/org/apache/pulsar/tests/integration/offload/TestFileSystemOffload.j
ava
added
tests/integration/src/test/java/org/apache/pulsar/tests/integration/offload/TestS3Offload.java changed 89.0% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/schema/Schemas.java changed 24.0% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/schema/SchemaTest.java changed 58.5% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/suites/PulsarTieredStorageTestS
uite.java
changed 23.5% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarCluster.java changed 3.2% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarClusterSpec.ja
va
changed 0.8% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarTestBase.java changed 48.7% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/upgrade/PulsarZKDowngradeTest.j
ava
changed 1.4% diff
tests/integration/src/test/java/org/apache/pulsar/tests/integration/utils/DockerUtils.java changed 18.7% diff
tests/pulsar-storm-test/src/test/java/org/apache/pulsar/storm/PulsarBoltTest.java changed 0.9% diff
tests/pulsar-storm-test/src/test/java/org/apache/pulsar/storm/PulsarSpoutTest.java changed 0.6% diff
tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/FileSyste
mConfigurationData.java
added
tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/FileSyste
mLedgerOffloaderFactory.java
added
tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/File
StoreBackedReadHandleImpl.java
added
tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/File
SystemManagedLedgerOffloader.java
added
tiered-storage/file-system/src/test/java/org/apache/bookkeeper/mledger/offload/filesystem/FileStore
TestBase.java
added
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBack
edInputStreamImpl.java
changed 3.0% diff
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBack
edReadHandleImpl.java
changed 8.6% diff
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/DataBlockHead
erImpl.java
changed 4.4% diff
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexB
lockImpl.java
changed 0.6% diff
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexE
ntryImpl.java
changed 10.1% diff

Python Programs (29 of 78):

NameStatusDeltaVisual Diff
bin/pulsar-managed-ledger-admin changed 13.6% diff
dashboard/django/collector.py changed 0.7% diff
dashboard/django/stats/models.py changed 2.3% diff
dashboard/django/stats/urls.py changed 24.0% diff
dashboard/django/stats/views.py changed 60.6% diff
dashboard/django/utils/__init__.py added
dashboard/django/utils/import_utils.py added
docker/pulsar-standalone/django/collector.py removed
docker/pulsar-standalone/django/dashboard/__init__.py removed
docker/pulsar-standalone/django/dashboard/settings.py removed
docker/pulsar-standalone/django/dashboard/urls.py removed
docker/pulsar-standalone/django/dashboard/wsgi.py removed
docker/pulsar-standalone/django/manage.py removed
docker/pulsar-standalone/django/stats/__init__.py removed
docker/pulsar-standalone/django/stats/admin.py removed
docker/pulsar-standalone/django/stats/apps.py removed
docker/pulsar-standalone/django/stats/migrations/0001_initial.py removed
docker/pulsar-standalone/django/stats/migrations/__init__.py removed
docker/pulsar-standalone/django/stats/models.py removed
docker/pulsar-standalone/django/stats/templatetags/__init__.py removed
docker/pulsar-standalone/django/stats/templatetags/stats_extras.py removed
docker/pulsar-standalone/django/stats/templatetags/table.py removed
docker/pulsar-standalone/django/stats/tests.py removed
docker/pulsar-standalone/django/stats/urls.py removed
docker/pulsar-standalone/django/stats/views.py removed
pulsar-client-cpp/python/pulsar/__init__.py changed 4.9% diff
pulsar-client-cpp/python/pulsar/functions/context.py changed 1.9% diff
pulsar-client-cpp/python/pulsar_test.py changed 14.1% diff
pulsar-functions/instance/src/main/python/contextimpl.py changed 1.3% diff

Shell Programs (19 of 61):

NameStatusDeltaVisual Diff
bin/pulsar changed 4.6% diff
bin/pulsar-daemon changed 2.3% diff
bin/pulsar-perf changed 2.2% diff
conf/bkenv.sh changed 17.0% diff
conf/pulsar_env.sh changed 12.5% diff
docker/build.sh changed 2.5% diff
docker/pulsar-standalone/django/collector.sh removed
docker/pulsar/scripts/install-pulsar-client-35.sh renamed 11.4% diff
docker/pulsar/scripts/install-pulsar-client-37.sh
pulsar-client-cpp/docker-build.sh changed 20.7% diff
pulsar-client-cpp/docker-format.sh changed 14.8% diff
pulsar-client-cpp/docker-lib-check.sh removed
pulsar-client-cpp/docker-tests.sh changed 6.0% diff
pulsar-client-cpp/docker/build-client-lib.sh changed 18.0% diff
pulsar-client-cpp/docker/build-wheels.sh changed 15.6% diff
pulsar-client-cpp/pkg/deb/docker-build-deb.sh changed 7.3% diff
src/check-binary-license changed 13.7% diff
src/gen-swagger.sh changed 25.0% diff
src/pulsar-io-gen changed 2.9% diff

CMake Files (3 of 7):

NameStatusDeltaVisual Diff
pulsar-client-cpp/CMakeLists.txt changed 4.1% diff
pulsar-client-cpp/lib/CMakeLists.txt changed 11.8% diff
pulsar-client-cpp/tests/CMakeLists.txt changed 5.7% diff

Configuration Files (19 of 45):

NameStatusDeltaVisual Diff
conf/bookkeeper.conf changed 0.3% diff
conf/broker.conf changed 9.7% diff
conf/standalone.conf changed 11.8% diff
deployment/terraform-ansible/templates/broker.conf changed 0.8% diff
docker/pulsar-standalone/conf/nginx-app.conf removed
docker/pulsar-standalone/conf/postgresql.conf removed
docker/pulsar-standalone/conf/supervisor-app.conf removed
pulsar-client-cpp/test-conf/standalone-ssl.conf changed 2.8% diff
pulsar-client-cpp/test-conf/standalone.conf changed 3.7% diff
pulsar-client-cpp/tests/authentication.conf changed 2.0% diff
pulsar-client-cpp/tests/standalone.conf changed 2.5% diff
pulsar-io/flume/src/test/resources/flume/sink.conf changed 2.1% diff
tests/docker-images/latest-version-image/conf/bookie.conf changed 12.9% diff
tests/docker-images/latest-version-image/conf/broker.conf changed 6.3% diff
tests/docker-images/latest-version-image/conf/functions_worker.conf changed 6.1% diff
tests/docker-images/latest-version-image/conf/global-zk.conf changed 6.2% diff
tests/docker-images/latest-version-image/conf/local-zk.conf changed 6.2% diff
tests/docker-images/latest-version-image/conf/presto_worker.conf changed 6.1% diff
tests/docker-images/latest-version-image/conf/proxy.conf changed 6.3% diff

Initialization Files (1 of 5):

NameStatusDeltaVisual Diff
docker/pulsar-standalone/conf/uwsgi.ini removed

SGML Documents (5 of 6):

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

XML Documents (142 of 174):

NameStatusDeltaVisual Diff
buildtools/pom.xml changed 1.1% diff
conf/filesystem_offload_core_site.xml added
dashboard/pom.xml changed 9.3% diff
distribution/io/pom.xml changed 0.7% diff
distribution/io/src/assemble/io.xml changed 2.9% diff
distribution/offloaders/pom.xml changed 3.7% diff
distribution/offloaders/src/assemble/offloaders.xml changed 12.8% diff
distribution/pom.xml changed 1.8% diff
distribution/server/pom.xml changed 0.4% diff
distribution/server/src/assemble/bin.xml changed 14.7% diff
distribution/server/src/assemble/src.xml changed 1.0% diff
docker/grafana/pom.xml changed 0.9% diff
docker/pom.xml changed 20.1% diff
docker/pom.xml.versionsBackup removed
docker/pulsar-all/pom.xml changed 0.5% diff
docker/pulsar-standalone/pom.xml changed 0.8% diff
docker/pulsar/pom.xml changed 19.4% diff
examples/flink/pom.xml changed 0.5% diff
examples/pom.xml changed 2.1% diff
examples/spark/pom.xml changed 0.7% diff
jclouds-shaded/pom.xml changed 0.5% diff
managed-ledger-shaded/pom.xml removed
managed-ledger/pom.xml changed 1.9% diff
pom.xml changed 8.8% diff
protobuf-shaded/pom.xml changed 2.6% diff
pulsar-broker-auth-athenz/pom.xml changed 4.5% diff
pulsar-broker-auth-sasl/pom.xml changed 2.6% diff
pulsar-broker-common/pom.xml changed 1.3% diff
pulsar-broker-shaded/pom.xml changed 2.1% diff
pulsar-broker/pom.xml changed 3.5% 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 2.9% diff
pulsar-client-admin/pom.xml changed 1.0% diff
pulsar-client-all/pom.xml changed 0.2% diff
pulsar-client-api/pom.xml changed 88.1% 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 20.8% 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 added
pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml added
pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml changed 3.6% diff
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/pom.xml added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/pom.xml added
pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml changed 7.1% diff
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml added
pulsar-client-shaded/pom.xml changed 1.6% diff
pulsar-client-tools-test/pom.xml changed 3.0% diff
pulsar-client-tools/pom.xml changed 0.9% diff
pulsar-client/pom.xml changed 6.4% diff
pulsar-common/pom.xml changed 6.3% diff
pulsar-discovery-service/pom.xml changed 3.0% diff
pulsar-flink/pom.xml changed 16.1% diff
pulsar-functions/api-java/pom.xml changed 1.7% diff
pulsar-functions/instance/pom.xml changed 3.6% diff
pulsar-functions/java-examples/pom.xml changed 1.7% diff
pulsar-functions/localrun-shaded/pom.xml changed 0.1% diff
pulsar-functions/localrun/pom.xml changed 6.5% 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 1.2% diff
pulsar-functions/secrets/pom.xml changed 1.7% diff
pulsar-functions/utils/pom.xml changed 4.7% diff
pulsar-functions/worker-shaded/pom.xml changed 18.9% diff
pulsar-functions/worker/pom.xml changed 0.5% diff
pulsar-io/aerospike/pom.xml changed 1.4% diff
pulsar-io/canal/pom.xml changed 1.4% diff
pulsar-io/cassandra/pom.xml changed 1.4% diff
pulsar-io/common/pom.xml changed 2.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 2.6% diff
pulsar-io/debezium/mongodb/pom.xml added
pulsar-io/debezium/mysql/pom.xml changed 1.6% diff
pulsar-io/debezium/pom.xml changed 4.2% diff
pulsar-io/debezium/postgres/pom.xml changed 1.6% diff
pulsar-io/docs/pom.xml changed 0.8% diff
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 1.9% diff
pulsar-io/hbase/pom.xml changed 1.1% diff
pulsar-io/hdfs2/pom.xml changed 1.3% diff
pulsar-io/hdfs3/pom.xml changed 1.4% diff
pulsar-io/influxdb/pom.xml changed 1.3% diff
pulsar-io/jdbc/pom.xml changed 1.1% diff
pulsar-io/kafka-connect-adaptor/pom.xml changed 2.4% diff
pulsar-io/kafka/pom.xml changed 1.5% diff
pulsar-io/kinesis/pom.xml changed 22.2% diff
pulsar-io/mongo/pom.xml changed 8.6% diff
pulsar-io/netty/pom.xml changed 8.2% diff
pulsar-io/pom.xml changed 1.5% 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 added
pulsar-proxy/pom.xml changed 1.8% diff
pulsar-spark/pom.xml changed 7.7% 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 2.5% diff
pulsar-storm/pom.xml changed 1.3% diff
pulsar-testclient/pom.xml changed 3.0% diff
pulsar-transaction/buffer/pom.xml removed
pulsar-transaction/common/pom.xml changed 1.3% diff
pulsar-transaction/coordinator/pom.xml changed 14.0% diff
pulsar-transaction/pom.xml changed 2.7% diff
pulsar-websocket/pom.xml changed 2.3% diff
pulsar-zookeeper-utils/pom.xml changed 5.2% diff
pulsar-zookeeper-utils/src/main/resources/META-INF/aop.xml changed 5.9% diff
pulsar-zookeeper/pom.xml changed 0.7% diff
tests/bc_2_0_0/pom.xml changed 0.7% diff
tests/bc_2_0_1/pom.xml changed 0.7% diff
tests/docker-images/java-test-functions/pom.xml changed 1.0% diff
tests/docker-images/latest-version-image/pom.xml changed 0.7% diff
tests/docker-images/pom.xml changed 2.0% diff
tests/integration/pom.xml changed 3.9% diff
tests/integration/src/test/resources/pulsar-backwards-compatibility.xml added
tests/integration/src/test/resources/pulsar-cli.xml changed 5.8% diff
tests/integration/src/test/resources/pulsar-messaging.xml added
tests/integration/src/test/resources/pulsar-schema-suite.xml added
tests/integration/src/test/resources/pulsar-schema.xml added
tests/integration/src/test/resources/pulsar.xml changed 19.7% diff
tests/integration/src/test/resources/tiered-file-system-suite.xml added
tests/integration/src/test/resources/tiered-filesystem-storage.xml added
tests/integration/src/test/resources/tiered-storage-suite.xml renamed 4.9% diff
tests/integration/src/test/resources/tiered-storage-jcloud-suite.xml
tests/integration/src/test/resources/tiered-storage.xml renamed 14.4% diff
tests/integration/src/test/resources/tiered-jcloud-storage.xml
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 0.9% diff
tests/pulsar-storm-test/pom.xml changed 2.4% diff
tiered-storage/file-system/pom.xml changed 1.1% diff
tiered-storage/jcloud/pom.xml changed 2.9% diff
tiered-storage/pom.xml changed 4.1% diff

CSS Style Sheets (all 1):

NameStatusDeltaVisual Diff
dashboard/django/stats/static/stats/additional.css changed 47.9% diff

HTML Pages (11 of 23):

NameStatusDeltaVisual Diff
dashboard/django/stats/templates/stats/messages.html changed 82.5%
dashboard/django/stats/templates/stats/peek.html removed
docker/pulsar-standalone/django/stats/templates/stats/base.html removed
docker/pulsar-standalone/django/stats/templates/stats/broker.html removed
docker/pulsar-standalone/django/stats/templates/stats/brokers.html removed
docker/pulsar-standalone/django/stats/templates/stats/clusters.html removed
docker/pulsar-standalone/django/stats/templates/stats/home.html removed
docker/pulsar-standalone/django/stats/templates/stats/namespace.html removed
docker/pulsar-standalone/django/stats/templates/stats/property.html removed
docker/pulsar-standalone/django/stats/templates/stats/topic.html removed
docker/pulsar-standalone/django/stats/templates/stats/topics.html removed

Property Files (1 of 10):

NameStatusDeltaVisual Diff
conf/presto/catalog/pulsar.properties changed 44.7% diff

Protocol Buffer Files (3 of 11):

NameStatusDeltaVisual Diff
pulsar-common/src/main/proto/PulsarApi.proto changed 100.0% diff
pulsar-common/src/main/proto/PulsarMarkers.proto changed 5.4% diff
pulsar-functions/proto/src/main/proto/Function.proto changed 0.8% diff

YAML Files (51 of 135):

NameStatusDeltaVisual Diff
conf/functions_worker.yml changed 21.5% diff
deployment/kubernetes/aws/bookkeeper.yaml changed 7.3% diff
deployment/kubernetes/aws/broker.yaml changed 9.5% diff
deployment/kubernetes/aws/monitoring.yaml changed 13.0% diff
deployment/kubernetes/aws/proxy.yaml changed 7.2% diff
deployment/kubernetes/aws/zookeeper.yaml changed 4.8% diff
deployment/kubernetes/generic/admin.yaml removed
deployment/kubernetes/generic/bookie.yaml removed
deployment/kubernetes/generic/broker.yaml removed
deployment/kubernetes/generic/cluster-metadata.yaml removed
deployment/kubernetes/generic/k8s-1-9-and-above/admin.yaml added
deployment/kubernetes/generic/k8s-1-9-and-above/bookie.yaml added
deployment/kubernetes/generic/k8s-1-9-and-above/broker.yaml added
deployment/kubernetes/generic/k8s-1-9-and-above/cluster-metadata.yaml added
deployment/kubernetes/generic/k8s-1-9-and-above/monitoring.yaml added
deployment/kubernetes/generic/k8s-1-9-and-above/proxy.yaml added
deployment/kubernetes/generic/k8s-1-9-and-above/zookeeper.yaml added
deployment/kubernetes/generic/monitoring.yaml removed
deployment/kubernetes/generic/original/admin.yaml added
deployment/kubernetes/generic/original/bookie.yaml added
deployment/kubernetes/generic/original/broker.yaml added
deployment/kubernetes/generic/original/cluster-metadata.yaml added
deployment/kubernetes/generic/original/monitoring.yaml added
deployment/kubernetes/generic/original/proxy.yaml added
deployment/kubernetes/generic/original/zookeeper.yaml added
deployment/kubernetes/generic/proxy.yaml removed
deployment/kubernetes/generic/zookeeper.yaml removed
deployment/kubernetes/google-kubernetes-engine/bookie.yaml changed 7.6% diff
deployment/kubernetes/google-kubernetes-engine/broker.yaml changed 6.5% diff
deployment/kubernetes/google-kubernetes-engine/monitoring.yaml changed 14.9% diff
deployment/kubernetes/google-kubernetes-engine/proxy.yaml changed 9.5% diff
deployment/kubernetes/google-kubernetes-engine/zookeeper.yaml changed 4.9% diff
deployment/kubernetes/helm/pulsar/templates/autorecovery-deployment.yaml changed 2.2% diff
deployment/kubernetes/helm/pulsar/templates/bookkeeper-statefulset.yaml changed 7.3% diff
deployment/kubernetes/helm/pulsar/templates/broker-deployment.yaml changed 15.7% diff
deployment/kubernetes/helm/pulsar/templates/dashboard-ingress.yaml changed 5.1% diff
deployment/kubernetes/helm/pulsar/templates/prometheus-pvc.yaml changed 14.0% diff
deployment/kubernetes/helm/pulsar/templates/proxy-deployment.yaml changed 2.1% diff
deployment/kubernetes/helm/pulsar/templates/pulsar-manager-admin-secret.yaml added
deployment/kubernetes/helm/pulsar/templates/pulsar-manager-deployment.yaml added
deployment/kubernetes/helm/pulsar/templates/pulsar-manager-service.yaml added
deployment/kubernetes/helm/pulsar/templates/zookeeper-statefulset.yaml changed 4.7% diff
deployment/kubernetes/helm/pulsar/values-mini.yaml changed 13.5% diff
deployment/kubernetes/helm/pulsar/values.yaml changed 27.5% diff
pulsar-io/debezium/mongodb/src/main/resources/debezium-mongodb-source-config.yaml added
pulsar-io/debezium/mongodb/src/main/resources/META-INF/services/pulsar-io.yaml added
pulsar-io/kinesis/src/main/resources/META-INF/services/pulsar-io.yaml changed 10.1% diff
pulsar-io/kinesis/src/test/resources/sinkConfig.yaml added
pulsar-io/kinesis/src/test/resources/sourceConfig.yaml added
pulsar-io/mongo/src/main/resources/META-INF/services/pulsar-io.yaml changed 11.6% diff
tiered-storage/file-system/src/main/resources/META-INF/services/pulsar-offloader.yaml added

Directories (179 of 1843):

NameStatus
dashboard/django/utils added
deployment/kubernetes/generic/k8s-1-9-and-above added
deployment/kubernetes/generic/original added
docker/pulsar-standalone/conf removed
docker/pulsar-standalone/django removed
docker/pulsar-standalone/django/dashboard removed
docker/pulsar-standalone/django/stats removed
docker/pulsar-standalone/django/stats/migrations removed
docker/pulsar-standalone/django/stats/templates removed
docker/pulsar-standalone/django/stats/templates/stats removed
docker/pulsar-standalone/django/stats/templatetags removed
managed-ledger-shaded removed
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/offload added
pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol added
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics added
pulsar-broker/src/main/java/org/apache/pulsar/broker/tools added
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction added
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer added
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl added
pulsar-broker/src/test/java/org/apache/pulsar/broker/protocol added
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction added
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/buffer added
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator added
pulsar-broker/src/test/java/org/apache/pulsar/schema added
pulsar-broker/src/test/java/org/apache/pulsar/schema/compatibility added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/interceptor added
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/transaction added
pulsar-client-cpp/generated removed
pulsar-client-cpp/generated/lib removed
pulsar-client-cpp/pkg/rpm/BUILD removed
pulsar-client-cpp/pkg/rpm/BUILDROOT removed
pulsar-client-cpp/pkg/rpm/SRPMS removed
pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8 added
pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9 added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8 added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src/test added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src/test/java added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src/test/java/org added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src/test/java/org/apache added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src/test/java/org/apache/pulsar added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src/test/java/org/apache/pulsar/client added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src/test/java/org/apache/pulsar/client/kaf
ka
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src/test/java/org/apache/pulsar/client/kaf
ka/compat
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src/test/java/org/apache/pulsar/client/kaf
ka/compat/examples
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/src/test/java/org/apache/pulsar/client/kaf
ka/compat/examples/utils
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9 added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java/org added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java/org/apache added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java/org/apache/pulsar added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java/org/apache/pulsar/client added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java/org/apache/pulsar/client/kaf
ka
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java/org/apache/pulsar/client/kaf
ka/compat
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java/org/apache/pulsar/client/kaf
ka/compat/examples
added
pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/src/test/java/org/apache/pulsar/client/kaf
ka/compat/examples/utils
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8 added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/consumer added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/producer added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/co
nsumer
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java/org added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java/org/apache added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java/org/apache/kafka added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java/org/apache/kafka/clients added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java/org/apache/kafka/clients/consumer added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java/org/apache/kafka/clients/producer added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java/org/apache/pulsar added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java/org/apache/pulsar/client added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java/org/apache/pulsar/client/kafka added
pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/test/java/org/apache/pulsar/client/kafka/tes
t
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9 added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/kafka added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/kafka/clients added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/kafka/clients/consumer added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/kafka/clients/producer added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/pulsar added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/pulsar/client added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/pulsar/client/kafka added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/pulsar/client/kafka/com
pat
added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/test added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/test/java added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/test/java/org added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/test/java/org/apache added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/test/java/org/apache/kafka added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/test/java/org/apache/kafka/clients added
pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/test/java/org/apache/kafka/clients/producer added
pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction added
pulsar-client/src/test/java/org/apache/pulsar/client/examples added
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes added
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/process added
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread added
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/worker added
pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/runtime/kubernetes added
pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/runtime/process added
pulsar-io/debezium/mongodb added
pulsar-io/debezium/mongodb/src added
pulsar-io/debezium/mongodb/src/main added
pulsar-io/debezium/mongodb/src/main/java added
pulsar-io/debezium/mongodb/src/main/java/org added
pulsar-io/debezium/mongodb/src/main/java/org/apache added
pulsar-io/debezium/mongodb/src/main/java/org/apache/pulsar added
pulsar-io/debezium/mongodb/src/main/java/org/apache/pulsar/io added
pulsar-io/debezium/mongodb/src/main/java/org/apache/pulsar/io/debezium added
pulsar-io/debezium/mongodb/src/main/java/org/apache/pulsar/io/debezium/mongodb added
pulsar-io/debezium/mongodb/src/main/resources added
pulsar-io/debezium/mongodb/src/main/resources/META-INF added
pulsar-io/debezium/mongodb/src/main/resources/META-INF/services added
pulsar-io/kinesis/src/test/resources added
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp added
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp added
pulsar-io/netty/src/test/java/org/apache/pulsar/io/netty/tcp added
pulsar-io/netty/src/test/java/org/apache/pulsar/io/netty/udp added
pulsar-metadata added
pulsar-metadata/src added
pulsar-metadata/src/main added
pulsar-metadata/src/main/java added
pulsar-metadata/src/main/java/org added
pulsar-metadata/src/main/java/org/apache added
pulsar-metadata/src/main/java/org/apache/pulsar added
pulsar-metadata/src/main/java/org/apache/pulsar/metadata added
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api added
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl added
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/zookeeper added
pulsar-metadata/src/test added
pulsar-metadata/src/test/java added
pulsar-metadata/src/test/java/org added
pulsar-metadata/src/test/java/org/apache added
pulsar-metadata/src/test/java/org/apache/pulsar added
pulsar-metadata/src/test/java/org/apache/pulsar/metadata added
pulsar-transaction/buffer removed
pulsar-transaction/buffer/src removed
pulsar-transaction/buffer/src/main removed
pulsar-transaction/buffer/src/main/java removed
pulsar-transaction/buffer/src/main/java/org removed
pulsar-transaction/buffer/src/main/java/org/apache removed
pulsar-transaction/buffer/src/main/java/org/apache/pulsar removed
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction removed
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer removed
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions moved
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/impl removed
pulsar-transaction/buffer/src/test removed
pulsar-transaction/buffer/src/test/java removed
pulsar-transaction/buffer/src/test/java/org removed
pulsar-transaction/buffer/src/test/java/org/apache removed
pulsar-transaction/buffer/src/test/java/org/apache/pulsar removed
pulsar-transaction/buffer/src/test/java/org/apache/pulsar/transaction removed
pulsar-transaction/buffer/src/test/java/org/apache/pulsar/transaction/buffer removed
pulsar-transaction/buffer/src/test/java/org/apache/pulsar/transaction/buffer/impl removed
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/stats added
tiered-storage/file-system/src/main added
tiered-storage/file-system/src/main/java added
tiered-storage/file-system/src/main/java/org added
tiered-storage/file-system/src/main/java/org/apache added
tiered-storage/file-system/src/main/java/org/apache/bookkeeper added
tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger added
tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload added
tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem added
tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl added
tiered-storage/file-system/src/main/resources added
tiered-storage/file-system/src/main/resources/META-INF added
tiered-storage/file-system/src/main/resources/META-INF/services added

Archives (1 of 5):

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

Licenses (4 of 34):

NameStatusDeltaVisual Diff
distribution/server/licenses/LICENSE-EDL-1.0.txt added
distribution/server/licenses/LICENSE-jcip.txt added
distribution/server/src/assemble/LICENSE.bin.txt changed 12.6% diff
pulsar-sql/presto-distribution/LICENSE changed 5.8% diff

Readme Files (6 of 18):

NameStatusDeltaVisual Diff
deployment/kubernetes/aws/README.md changed 9.2% diff
deployment/kubernetes/helm/README.md changed 3.4% diff
deployment/kubernetes/README.md changed 9.3% diff
dev/README.md changed 5.3% diff
pulsar-client-cpp/README.md changed 3.7% diff
README.md changed 2.0% diff

Text Files (8 of 47):

NameStatusDeltaVisual Diff
dashboard/Dockerfile changed 6.5% diff
dashboard/requirements.txt added
distribution/server/src/assemble/NOTICE.bin.txt changed 0.8% diff
docker/pulsar-standalone/conf/uwsgi_params removed
docker/pulsar-standalone/Dockerfile changed 73.1% diff
docker/pulsar/Dockerfile changed 20.6% diff
pulsar-client-cpp/pkg/deb/Dockerfile changed 1.3% diff
pulsar-client-cpp/pkg/rpm/Dockerfile changed 1.3% diff

Packages Compared:

apache-pulsar-2.4.2-src.tar.gz
apache-pulsar-2.5.0-src.tar.gz


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