You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by aa...@apache.org on 2019/09/05 01:22:32 UTC
[pulsar] branch doc1 updated (520b336 -> 3328ec5)
This is an automated email from the ASF dual-hosted git repository.
aahmed pushed a change to branch doc1
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
discard 520b336 Update supported python osx version docs
add 687406e Admin pod should use broker service to discover broker pods (#4995)
add 40fbf5d support parse batch entry payload (#4992)
add c3cb5eb ### Motivation (#4991)
add 6b6bc52 Added powered-by page (#5018)
add d3f30fc [dashboard] fix format single message raw bytes (#5031)
add dd5b4d0 [docker]Fix the problem of missing dependencies less (#5034)
add a3609ef Consumer subscribe with AutoConsumeSchema will throw npe (#4960)
add 6ef39ed [doc] Pulsar Functions: CLI (#4968)
add ff41871 Clarification in DLQ documentation (#5029)
add 4fa87a4 [dashboard] fix admin path (#5030)
add bf94890 Add support in cpp client for 1 partitioned topic (#5016)
add 8d32b58 Adding back Prometheus TYPE definitions; fixed duplicate TYPE errors; fixed format issue in metricWithRemoteCluster; added test for Prometheus types (#4183)
add dc7ce39 [pulsar-client-cpp] cmake isolate auto gen srcs (#5013)
add 0b1e3b3 [pulsar-perf] Introduce number of threads in perf producer program (#5036)
add 0af3527 Add Connector Admin CLI guide (#5028)
add 99289f8 add more powered-by company (#5054)
add c56ad9d Change method name to avoid being run as test (#5044)
add 4ba8b6d [pulsar-broker] add broker-bookie mTLS support (#5042)
add 40d6248 Fix pulsar sink and source state (#5046)
add d22e014 Reload zk cache asynchronously (#5049)
add 147c3c8 Add compatibility check for primitive schema types (#5051)
add 41430ce [Pulsar IO]Support reload Source and Sink for Pulsar IO (#5008)
add 588b166 [schema] support uploading key/value schema using Pulsar admin (#5000)
add 35f7590 Reduce char[] creation on jvm heap. (#5055)
add c32b402 Fixes not owned bundles got selected when broker overloading (#5002)
add 9ed91eb Fix Port Manager (#5024)
add 7e1c143 [admin] extract schema support no null (#5048)
add 8b0d726 [doc] Improve Pulsar Security-token-client (#5039)
add b696d90 [doc] Improve Pulsar Security Overview (#5014)
add 83365eb [website] Added more companies using Pulsar (#5063)
add a4cfcd7 add different cache flags for size() and toString() (#5040)
add f7aad57 [website]Support multi version for swagger (#5032)
add 6a67ae0 modify BatcherBuilder interface and it's subs to implement java.io.Serializable (#5068)
add d8db529 [website] add OVH in Pulsar users (#5072)
add 783c4ad [doc] Improve Pulsar security-tls-transport (#5027)
add e231d22 [k8s] convert to valid pod name part with k8s function runtime (#4996)
add e78beaa [doc] Improve Pulsar Security-athenz (#5053)
add bc76613 Fix : ConsumerStatsTest.testAsyncCallOnPartitionedTopic is flaky (#5066)
add 73b8669 Remove duplicate data from views screen (#5074)
add d9c0a10 Add checkstyle validation and fix style violations in the common module (#4989)
add 3cbfa10 Use "info" as the default root logger level (#5079)
add 26fe6b0 [doc] Improve Pulsar security-tls-authentication (#5038)
add 5b266b4 Avoid unnecessary allocations of PositionImpl (#5082)
add c993375 [bookkeeper] Don't return DEFAULT_RACK if ZkBookieRackAffinityMapping can't resolve network location (#5067)
add 4cd25ee [admin] DeleteBookieRack should remove the rack info from zookeeper (#5084)
add f1eae9c [Doc] Add configuration description for Java client (#5087)
add 1565e4e Add document for pulsar IO netty (#5077)
add 2699123 [docs] Removed Java only warning for compacted read flag (#5085)
add 695eedc feat: add turtlequeue to users (#5090)
add 0917f8e [Doc] Add *How to Use Pulsar Connectors* Guide (#5071)
add b8aa2c9 [doc] Improve Pulsar Security Kerberos (#5069)
add 2ed7d6e [doc]Add document for debug connector (#5041)
add 2d244d5 Update concepts-messaging.md (#5058)
add aaca33b remove misleading comment in handleSend (#5097)
add 12e46c6 add notes (#5078)
add 801b1f7 [doc] Improve Pulsar security authorization (#5070)
add d0bde68 [website]The website cannot get the swagger version file (#5076)
add 5212497 update website for 2.4.1 release (#5080)
add 16c15ed [doc] Improve Pulsar deployment AWS (#5093)
add 3328ec5 Update supported python osx version docs
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (520b336)
\
N -- N -- N refs/heads/doc1 (3328ec5)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
bin/pulsar | 2 +-
conf/broker.conf | 28 +
conf/log4j2.yaml | 3 +-
conf/standalone.conf | 29 +
dashboard/Dockerfile | 6 +-
.../django/stats/templates/stats/messages.html | 35 +-
dashboard/django/stats/urls.py | 6 +-
dashboard/django/stats/views.py | 255 +-
.../django/utils}/__init__.py | 0
.../django/utils/import_utils.py | 16 +-
dashboard/requirements.txt | 8 +
.../generic/k8s-1-9-and-above/admin.yaml | 4 +-
deployment/kubernetes/generic/original/admin.yaml | 4 +-
docker/pulsar/Dockerfile | 2 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 18 +-
.../org/apache/bookkeeper/test/PortManager.java | 8 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 30 +
.../pulsar/broker/BookKeeperClientFactoryImpl.java | 12 +
.../apache/pulsar/broker/admin/impl/SinksBase.java | 15 +
.../pulsar/broker/admin/impl/SourcesBase.java | 15 +
.../org/apache/pulsar/broker/admin/v2/Bookies.java | 23 +-
.../pulsar/broker/admin/v2/SchemasResource.java | 76 +-
.../broker/loadbalance/impl/OverloadShedder.java | 4 +-
.../apache/pulsar/broker/service/ServerCnx.java | 2 -
.../nonpersistent/NonPersistentSubscription.java | 7 +-
.../service/persistent/PersistentSubscription.java | 7 +-
.../service/schema/SchemaRegistryServiceImpl.java | 6 +-
.../stats/prometheus/NamespaceStatsAggregator.java | 5 +
.../pulsar/broker/stats/prometheus/TopicStats.java | 23 +
.../pulsar/broker/admin/AdminApiSchemaTest.java | 10 +
.../apache/pulsar/broker/admin/BookiesApiTest.java | 115 +
.../loadbalance/impl/OverloadShedderTest.java | 9 +
.../pulsar/broker/stats/PrometheusMetricsTest.java | 97 +
.../websocket/proxy/ProxyAuthenticationTest.java | 8 +-
.../java/org/apache/pulsar/client/admin/Sinks.java | 8 +
.../org/apache/pulsar/client/admin/Sources.java | 9 +
.../pulsar/client/admin/internal/SchemasImpl.java | 12 +-
.../pulsar/client/admin/internal/SinksImpl.java | 10 +
.../pulsar/client/admin/internal/SourcesImpl.java | 10 +
.../apache/pulsar/client/api/BatcherBuilder.java | 4 +-
pulsar-client-cpp/.gitignore | 7 +-
pulsar-client-cpp/CMakeLists.txt | 4 +
pulsar-client-cpp/include/pulsar/Message.h | 3 +
.../src/utils.h => include/pulsar/MessageBatch.h} | 41 +-
pulsar-client-cpp/include/pulsar/MessageId.h | 10 +-
pulsar-client-cpp/lib/CMakeLists.txt | 17 +-
pulsar-client-cpp/lib/ClientImpl.cc | 8 +-
pulsar-client-cpp/lib/Commands.h | 5 +-
pulsar-client-cpp/lib/Message.cc | 2 +
pulsar-client-cpp/lib/MessageBatch.cc | 57 +
pulsar-client-cpp/lib/MultiTopicsConsumerImpl.cc | 16 +-
pulsar-client-cpp/python/pulsar/__init__.py | 42 +
pulsar-client-cpp/python/src/message.cc | 17 +
pulsar-client-cpp/python/src/utils.h | 1 +
pulsar-client-cpp/tests/BasicEndToEndTest.cc | 69 +
pulsar-client-cpp/tests/BatchMessageTest.cc | 61 +-
pulsar-client-cpp/tests/CMakeLists.txt | 2 +-
pulsar-client-cpp/tests/ConsumerStatsTest.cc | 28 +-
.../org/apache/pulsar/admin/cli/CmdSchemas.java | 31 +-
.../java/org/apache/pulsar/admin/cli/CmdSinks.java | 10 +
.../org/apache/pulsar/admin/cli/CmdSources.java | 10 +
.../pulsar/admin/cli/utils/SchemaExtractor.java | 11 +-
.../pulsar/client/impl/DefaultBatcherBuilder.java | 2 +
.../pulsar/client/impl/KeyBasedBatcherBuilder.java | 2 +
.../org/apache/pulsar/client/impl/MessageImpl.java | 2 +-
.../pulsar/client/impl/PulsarClientImpl.java | 11 +-
.../client/impl/schema/AutoConsumeSchema.java | 53 +-
pulsar-common/pom.xml | 20 +
.../client/api/url/DataURLStreamHandler.java | 6 +
.../api/url/PulsarURLStreamHandlerFactory.java | 4 +
.../java/org/apache/pulsar/client/api/url/URL.java | 3 +
.../api/url/package-info.java} | 9 +-
.../common/allocator/PulsarByteBufAllocator.java | 3 +
.../package-info.java} | 9 +-
.../pulsar/common/api/raw/MessageParser.java | 20 +-
.../apache/pulsar/common/api/raw/RawMessage.java | 18 +-
.../apache/pulsar/common/api/raw/RawMessageId.java | 3 +
.../common/api/raw/ReferenceCountedObject.java | 5 +
.../raw/{RawMessageId.java => package-info.java} | 9 +-
.../common/compression/CompressionCodec.java | 9 +-
.../common/compression/CompressionCodecLZ4.java | 8 +-
.../common/compression/CompressionCodecNone.java | 6 +-
.../compression/CompressionCodecProvider.java | 9 +
.../common/compression/CompressionCodecSnappy.java | 7 +-
.../common/compression/CompressionCodecZLib.java | 2 +-
.../common/compression/CompressionCodecZstd.java | 2 +-
.../package-info.java} | 9 +-
.../common/conf/InternalConfigurationData.java | 3 +
.../RawMessageId.java => conf/package-info.java} | 9 +-
.../pulsar/common/functions/ConsumerConfig.java | 9 +-
.../pulsar/common/functions/FunctionConfig.java | 25 +-
.../pulsar/common/functions/FunctionState.java | 15 +-
.../apache/pulsar/common/functions/Resources.java | 18 +-
.../pulsar/common/functions/UpdateOptions.java | 4 +-
.../org/apache/pulsar/common/functions/Utils.java | 15 +-
.../pulsar/common/functions/WindowConfig.java | 8 +-
.../apache/pulsar/common/functions/WorkerInfo.java | 5 +-
.../package-info.java} | 9 +-
.../pulsar/common/io/ConnectorDefinition.java | 15 +-
.../org/apache/pulsar/common/io/SinkConfig.java | 15 +-
.../org/apache/pulsar/common/io/SourceConfig.java | 17 +-
.../raw/RawMessageId.java => io/package-info.java} | 9 +-
.../pulsar/common/lookup/data/LookupData.java | 23 +-
.../data/package-info.java} | 9 +-
.../org/apache/pulsar/common/naming/Constants.java | 3 +
.../org/apache/pulsar/common/naming/Metadata.java | 3 +
.../apache/pulsar/common/naming/NamespaceName.java | 12 +-
.../apache/pulsar/common/naming/ServiceUnitId.java | 13 +-
.../apache/pulsar/common/naming/TopicDomain.java | 3 +
.../org/apache/pulsar/common/naming/TopicName.java | 48 +-
.../RawMessageId.java => naming/package-info.java} | 9 +-
.../org/apache/pulsar/common/nar/FileUtils.java | 10 +-
.../apache/pulsar/common/nar/NarClassLoader.java | 8 +-
.../org/apache/pulsar/common/nar/NarUnpacker.java | 5 +-
.../RawMessageId.java => nar/package-info.java} | 9 +-
.../RawMessageId.java => net/package-info.java} | 9 +-
.../common/partition/PartitionedTopicMetadata.java | 3 +
.../package-info.java} | 9 +-
.../pulsar/common/policies/AutoFailoverPolicy.java | 7 +-
.../common/policies/NamespaceIsolationPolicy.java | 23 +-
.../pulsar/common/policies/data/AuthAction.java | 8 +-
.../pulsar/common/policies/data/AuthPolicies.java | 9 +-
.../policies/data/AutoFailoverPolicyData.java | 8 +-
.../policies/data/AutoFailoverPolicyType.java | 7 +-
.../pulsar/common/policies/data/BacklogQuota.java | 21 +-
.../policies/data/BookieAffinityGroupData.java | 3 +
.../pulsar/common/policies/data/BookieInfo.java | 3 +
.../policies/data/BookiesRackConfiguration.java | 21 +-
.../common/policies/data/BrokerAssignment.java | 3 +
.../data/BrokerNamespaceIsolationData.java | 6 +-
.../pulsar/common/policies/data/BrokerStatus.java | 3 +
.../pulsar/common/policies/data/BundlesData.java | 6 +-
.../pulsar/common/policies/data/ClusterData.java | 6 +-
.../pulsar/common/policies/data/ConsumerStats.java | 31 +-
.../pulsar/common/policies/data/DispatchRate.java | 6 +-
.../pulsar/common/policies/data/ErrorData.java | 3 +
.../common/policies/data/ExceptionInformation.java | 3 +
.../pulsar/common/policies/data/FailureDomain.java | 3 +
.../pulsar/common/policies/data/FunctionStats.java | 110 +-
.../common/policies/data/FunctionStatus.java | 14 +-
.../pulsar/common/policies/data/LocalPolicies.java | 3 +
.../policies/data/NamespaceIsolationData.java | 7 +-
.../policies/data/NamespaceOwnershipStatus.java | 6 +
.../policies/data/NonPersistentPublisherStats.java | 3 +-
.../data/NonPersistentReplicatorStats.java | 5 +-
.../data/NonPersistentSubscriptionStats.java | 5 +-
.../policies/data/NonPersistentTopicStats.java | 18 +-
.../data/PartitionedTopicInternalStats.java | 7 +-
.../policies/data/PartitionedTopicStats.java | 7 +-
.../common/policies/data/PersistencePolicies.java | 6 +-
.../policies/data/PersistentOfflineTopicStats.java | 29 +-
.../data/PersistentTopicInternalStats.java | 12 +-
.../common/policies/data/PersistentTopicStats.java | 2 +-
.../pulsar/common/policies/data/Policies.java | 28 +-
.../common/policies/data/PublisherStats.java | 25 +-
.../common/policies/data/ReplicatorStats.java | 27 +-
.../pulsar/common/policies/data/ResourceQuota.java | 54 +-
.../common/policies/data/RetentionPolicies.java | 1 +
.../SchemaAutoUpdateCompatibilityStrategy.java | 2 +-
.../pulsar/common/policies/data/SinkStatus.java | 14 +-
.../pulsar/common/policies/data/SourceStatus.java | 14 +-
.../pulsar/common/policies/data/SubscribeRate.java | 3 +
.../common/policies/data/SubscriptionAuthMode.java | 6 +-
.../common/policies/data/SubscriptionStats.java | 29 +-
.../pulsar/common/policies/data/TenantInfo.java | 7 +-
.../pulsar/common/policies/data/TopicStats.java | 28 +-
.../policies/data/WorkerFunctionInstanceStats.java | 8 +-
.../data/package-info.java} | 9 +-
.../policies/impl/AutoFailoverPolicyFactory.java | 3 +
.../common/policies/impl/MinAvailablePolicy.java | 9 +-
.../policies/impl/NamespaceIsolationPolicies.java | 39 +-
.../impl/NamespaceIsolationPolicyImpl.java | 25 +-
.../impl/package-info.java} | 9 +-
.../package-info.java} | 9 +-
.../apache/pulsar/common/protocol/ByteBufPair.java | 8 +-
.../pulsar/common/protocol/CommandUtils.java | 6 +-
.../apache/pulsar/common/protocol/Commands.java | 50 +-
.../org/apache/pulsar/common/protocol/Markers.java | 11 +-
.../pulsar/common/protocol/PulsarDecoder.java | 7 +-
.../pulsar/common/protocol/PulsarHandler.java | 9 +-
.../package-info.java} | 9 +-
.../common/protocol/schema/BytesSchemaVersion.java | 22 +-
.../protocol/schema/DeleteSchemaResponse.java | 3 +
.../common/protocol/schema/EmptyVersion.java | 3 +
.../schema/GetAllVersionsSchemaResponse.java | 6 +-
.../common/protocol/schema/GetSchemaResponse.java | 3 +
.../protocol/schema/IsCompatibilityResponse.java | 3 +
.../common/protocol/schema/LatestVersion.java | 3 +
.../protocol/schema/LongSchemaVersionResponse.java | 3 +
.../common/protocol/schema/PostSchemaPayload.java | 3 +
.../common/protocol/schema/PostSchemaResponse.java | 3 +
.../pulsar/common/protocol/schema/SchemaData.java | 5 +-
.../common/protocol/schema/SchemaInfoUtil.java | 7 +-
.../common/protocol/schema/SchemaVersion.java | 3 +
.../schema/package-info.java} | 9 +-
.../common/sasl/JAASCredentialsContainer.java | 10 +-
.../apache/pulsar/common/sasl/KerberosName.java | 51 +-
.../pulsar/common/sasl/TGTRefreshThread.java | 5 +-
.../RawMessageId.java => sasl/package-info.java} | 9 +-
.../apache/pulsar/common/stats/AllocatorStats.java | 15 +
.../common/stats/JvmDefaultGCMetricsLogger.java | 9 +-
.../pulsar/common/stats/JvmG1GCMetricsLogger.java | 3 +
.../pulsar/common/stats/JvmGCMetricsLogger.java | 6 +-
.../org/apache/pulsar/common/stats/JvmMetrics.java | 12 +-
.../org/apache/pulsar/common/stats/Metrics.java | 19 +-
.../RawMessageId.java => stats/package-info.java} | 9 +-
.../common/util/ClientSslContextRefresher.java | 5 +-
.../apache/pulsar/common/util/DateFormatter.java | 2 +-
.../common/util/DefaultSslContextBuilder.java | 1 +
.../org/apache/pulsar/common/util/FieldParser.java | 56 +-
.../common/util/FileModifiedTimeUpdater.java | 7 +-
.../org/apache/pulsar/common/util/FutureUtil.java | 5 +-
.../java/org/apache/pulsar/common/util/Hash.java | 7 +-
.../apache/pulsar/common/util/KeyStoreHolder.java | 5 +
.../apache/pulsar/common/util/Murmur3_32Hash.java | 7 +-
.../util/NamespaceBundleStatsComparator.java | 1 -
.../pulsar/common/util/NettySslContextBuilder.java | 10 +-
.../apache/pulsar/common/util/NumberFormat.java | 3 +
.../pulsar/common/util/ObjectMapperFactory.java | 1 +
.../org/apache/pulsar/common/util/RateLimiter.java | 50 +-
.../pulsar/common/util/RelativeTimeUtil.java | 5 +-
.../apache/pulsar/common/util/SecurityUtility.java | 28 +-
.../common/util/SslContextAutoRefreshBuilder.java | 8 +-
.../common/util/collections/ConcurrentBitSet.java | 3 +
.../util/collections/ConcurrentLongHashMap.java | 20 +-
.../util/collections/ConcurrentLongPairSet.java | 44 +-
.../util/collections/ConcurrentOpenHashMap.java | 17 +-
.../util/collections/ConcurrentOpenHashSet.java | 19 +-
.../ConcurrentOpenLongPairRangeSet.java | 41 +-
.../collections/ConcurrentSortedLongPairSet.java | 9 +-
.../collections/GrowableArrayBlockingQueue.java | 7 +-
.../collections/GrowablePriorityLongPairQueue.java | 39 +-
.../common/util/collections/LongPairRangeSet.java | 76 +-
.../common/util/collections/LongPairSet.java | 34 +-
.../util/collections/TripleLongPriorityQueue.java | 26 +-
.../collections/package-info.java} | 9 +-
.../pulsar/common/util/netty/EventLoopUtil.java | 6 +-
.../netty/package-info.java} | 9 +-
.../RawMessageId.java => util/package-info.java} | 9 +-
.../util/protobuf/ByteBufCodedInputStream.java | 5 +-
.../util/protobuf/ByteBufCodedOutputStream.java | 5 +-
.../protobuf/package-info.java} | 9 +-
.../policies/data/loadbalancer/BrokerUsage.java | 14 +-
.../policies/data/loadbalancer/JSONWritable.java | 7 +-
.../policies/data/loadbalancer/JvmUsage.java | 2 +-
.../data/loadbalancer/LoadManagerReport.java | 43 +-
.../policies/data/loadbalancer/LoadReport.java | 13 +-
.../data/loadbalancer/LoadReportDeserializer.java | 9 +-
.../data/loadbalancer/LocalBrokerData.java | 12 +-
.../data/loadbalancer/NamespaceBundleStats.java | 18 +-
.../policies/data/loadbalancer/NamespaceUsage.java | 28 +-
.../data/loadbalancer/ResourceUnitRanking.java | 53 +-
.../policies/data/loadbalancer/ResourceUsage.java | 5 +-
.../data/loadbalancer/ServiceLookupData.java | 12 +-
.../data/loadbalancer/SystemResourceUsage.java | 4 +-
.../data/loadbalancer/package-info.java} | 9 +-
.../ConcurrentOpenLongPairRangeSetTest.java | 12 +
.../pulsar/functions/instance/ContextImpl.java | 16 +-
.../functions/instance/JavaInstanceRunnable.java | 6 +-
.../pulsar/functions/instance/ContextImplTest.java | 25 +-
.../functions/runtime/KubernetesRuntime.java | 17 +-
.../functions/runtime/KubernetesRuntimeTest.java | 97 +
.../pulsar/functions/worker/ConnectorsManager.java | 6 +-
.../functions/worker/rest/api/ComponentImpl.java | 17 +
.../pulsar/testclient/PerformanceProducer.java | 358 +-
.../zookeeper/ZkBookieRackAffinityMapping.java | 10 +-
.../pulsar/zookeeper/ZooKeeperDataCache.java | 19 +-
.../zookeeper/ZkBookieRackAffinityMappingTest.java | 21 +-
site2/.gitignore | 2 +-
site2/docs/client-libraries-java.md | 30 +-
site2/docs/concepts-messaging.md | 27 +-
site2/docs/cookbooks-compaction.md | 7 +-
site2/docs/deploy-aws.md | 83 +-
site2/docs/functions-cli.md | 195 +
site2/docs/io-debug.md | 328 +
site2/docs/io-netty.md | 127 +
site2/docs/io-use.md | 1504 +++
site2/docs/reference-connector-admin.md | 600 ++
site2/docs/reference-pulsar-admin.md | 503 +-
site2/docs/security-athenz.md | 30 +-
site2/docs/security-authorization.md | 46 +-
site2/docs/security-kerberos.md | 107 +-
site2/docs/security-overview.md | 20 +-
site2/docs/security-tls-authentication.md | 42 +-
site2/docs/security-tls-transport.md | 92 +-
site2/docs/security-token-client.md | 19 +-
site2/website/core/Footer.js | 18 +-
site2/website/data/users.js | 230 +
site2/website/pages/en/admin-rest-api.js | 5 +-
site2/website/pages/en/functions-rest-api.js | 3 +-
site2/website/pages/en/index.js | 37 +
site2/website/pages/en/powered-by.js | 60 +
site2/website/pages/en/sink-rest-api.js | 3 +-
site2/website/pages/en/source-rest-api.js | 3 +-
site2/website/release-notes.md | 95 +
site2/website/sidebars.json | 4 +
site2/website/static/css/custom.css | 51 +-
site2/website/static/js/custom.js | 15 +-
site2/website/static/js/getSwaggerByVersion.js | 24 +
site2/website/static/js/pjax-api.min.js | 4 -
site2/website/static/swagger/2.3.0/swagger.json | 8191 +++++++++++++++++
.../static/swagger/2.3.0/swaggerfunctions.json | 3431 +++++++
.../website/static/swagger/2.3.0/swaggersink.json | 3038 ++++++
.../static/swagger/2.3.0/swaggersource.json | 3038 ++++++
site2/website/static/swagger/2.3.1/swagger.json | 8191 +++++++++++++++++
.../static/swagger/2.3.1/swaggerfunctions.json | 3431 +++++++
.../website/static/swagger/2.3.1/swaggersink.json | 3038 ++++++
.../static/swagger/2.3.1/swaggersource.json | 3038 ++++++
site2/website/static/swagger/2.3.2/swagger.json | 8191 +++++++++++++++++
.../static/swagger/2.3.2/swaggerfunctions.json | 3431 +++++++
.../website/static/swagger/2.3.2/swaggersink.json | 3038 ++++++
.../static/swagger/2.3.2/swaggersource.json | 3038 ++++++
site2/website/static/swagger/2.4.0/swagger.json | 9698 ++++++++++++++++++++
.../static/swagger/2.4.0/swaggerfunctions.json | 1496 +++
.../website/static/swagger/2.4.0/swaggersink.json | 926 ++
.../static/swagger/2.4.0/swaggersource.json | 860 ++
.../admin-api-non-persistent-topics.md | 264 +
.../version-2.4.1/admin-api-overview.md | 89 +
.../version-2.4.1/admin-api-partitioned-topics.md | 377 +
.../version-2.4.1/administration-dashboard.md | 60 +
.../version-2.4.1/administration-upgrade.md | 153 +
.../version-2.4.1}/client-libraries-java.md | 33 +-
.../version-2.4.1}/concepts-messaging.md | 30 +-
.../version-2.4.1/concepts-tiered-storage.md | 18 +
.../version-2.4.1}/cookbooks-compaction.md | 10 +-
.../versioned_docs/version-2.4.1/functions-api.md | 721 ++
.../versioned_docs/version-2.4.1/functions-cli.md | 196 +
.../version-2.4.1/functions-debug.md | 448 +
.../version-2.4.1/functions-deploy.md | 211 +
.../version-2.4.1/functions-develop.md | 617 ++
.../version-2.4.1/functions-overview-new.md | 190 +
.../version-2.4.1/functions-overview.md | 513 ++
.../version-2.4.1/functions-runtime.md | 143 +
.../version-2.4.1/getting-started-standalone.md | 226 +
.../versioned_docs/version-2.4.1/io-cdc-canal.md | 175 +
.../version-2.4.1/io-cdc-debezium.md | 261 +
.../versioned_docs/version-2.4.1/io-connectors.md | 31 +
.../versioned_docs/version-2.4.1/io-debug.md | 329 +
.../versioned_docs/version-2.4.1/io-develop.md | 196 +
.../versioned_docs/version-2.4.1/io-jdbc.md | 24 +
.../versioned_docs/version-2.4.1/io-netty.md | 148 +
.../website/versioned_docs/version-2.4.1/io-use.md | 1505 +++
.../version-2.4.1/reference-configuration.md | 496 +
.../version-2.4.1/reference-connector-admin.md | 601 ++
.../version-2.4.1/reference-metrics.md | 244 +
.../version-2.4.1}/reference-pulsar-admin.md | 506 +-
.../schema-evolution-compatibility.md | 784 ++
.../version-2.4.1/schema-get-started.md | 91 +
.../versioned_docs/version-2.4.1/schema-manage.md | 786 ++
.../version-2.4.1/schema-understand.md | 576 ++
.../version-2.4.1/security-athenz.md | 89 +
.../version-2.4.1/security-authorization.md | 100 +
.../version-2.4.1}/security-kerberos.md | 110 +-
.../version-2.4.1/security-overview.md | 38 +
.../version-2.4.1}/security-tls-authentication.md | 45 +-
.../version-2.4.1/security-tls-transport.md | 230 +
.../version-2.4.1}/security-token-client.md | 22 +-
.../versioned_sidebars/version-2.4.1-sidebars.json | 154 +
site2/website/versions.json | 1 +
src/gen-swagger.sh | 9 +-
tests/docker-images/java-test-functions/pom.xml | 7 +
.../pulsar/tests/integration/io/TestStateSink.java | 51 +
.../tests/integration/io/TestStateSource.java | 54 +
.../integration/functions/PulsarStateTest.java | 257 +-
.../tests/integration/schema/SchemaTest.java | 182 +-
.../pulsar/tests/integration/schema/Schemas.java | 6 +
366 files changed, 84374 insertions(+), 2905 deletions(-)
copy {docker/pulsar-standalone/django/stats/templatetags => dashboard/django/utils}/__init__.py (100%)
copy src/gen-swagger.sh => dashboard/django/utils/import_utils.py (71%)
mode change 100755 => 100644
create mode 100644 dashboard/requirements.txt
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/BookiesApiTest.java
copy pulsar-client-cpp/{python/src/utils.h => include/pulsar/MessageBatch.h} (54%)
create mode 100644 pulsar-client-cpp/lib/MessageBatch.cc
copy pulsar-common/src/main/java/org/apache/pulsar/{common/api/raw/RawMessageId.java => client/api/url/package-info.java} (91%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => allocator/package-info.java} (89%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/api/raw/{RawMessageId.java => package-info.java} (89%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => compression/package-info.java} (88%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => conf/package-info.java} (90%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => functions/package-info.java} (89%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => io/package-info.java} (91%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => lookup/data/package-info.java} (91%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => naming/package-info.java} (89%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => nar/package-info.java} (91%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => net/package-info.java} (90%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => partition/package-info.java} (91%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => policies/data/package-info.java} (87%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => policies/impl/package-info.java} (90%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => policies/package-info.java} (91%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => protocol/package-info.java} (91%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => protocol/schema/package-info.java} (89%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => sasl/package-info.java} (88%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => stats/package-info.java} (88%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => util/collections/package-info.java} (86%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => util/netty/package-info.java} (85%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => util/package-info.java} (91%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{api/raw/RawMessageId.java => util/protobuf/package-info.java} (87%)
copy pulsar-common/src/main/java/org/apache/pulsar/{common/api/raw/RawMessageId.java => policies/data/loadbalancer/package-info.java} (87%)
create mode 100644 site2/docs/functions-cli.md
create mode 100644 site2/docs/io-debug.md
create mode 100644 site2/docs/io-use.md
create mode 100644 site2/docs/reference-connector-admin.md
create mode 100644 site2/website/data/users.js
create mode 100644 site2/website/pages/en/powered-by.js
create mode 100644 site2/website/static/js/getSwaggerByVersion.js
delete mode 100644 site2/website/static/js/pjax-api.min.js
create mode 100644 site2/website/static/swagger/2.3.0/swagger.json
create mode 100644 site2/website/static/swagger/2.3.0/swaggerfunctions.json
create mode 100644 site2/website/static/swagger/2.3.0/swaggersink.json
create mode 100644 site2/website/static/swagger/2.3.0/swaggersource.json
create mode 100644 site2/website/static/swagger/2.3.1/swagger.json
create mode 100644 site2/website/static/swagger/2.3.1/swaggerfunctions.json
create mode 100644 site2/website/static/swagger/2.3.1/swaggersink.json
create mode 100644 site2/website/static/swagger/2.3.1/swaggersource.json
create mode 100644 site2/website/static/swagger/2.3.2/swagger.json
create mode 100644 site2/website/static/swagger/2.3.2/swaggerfunctions.json
create mode 100644 site2/website/static/swagger/2.3.2/swaggersink.json
create mode 100644 site2/website/static/swagger/2.3.2/swaggersource.json
create mode 100644 site2/website/static/swagger/2.4.0/swagger.json
create mode 100644 site2/website/static/swagger/2.4.0/swaggerfunctions.json
create mode 100644 site2/website/static/swagger/2.4.0/swaggersink.json
create mode 100644 site2/website/static/swagger/2.4.0/swaggersource.json
create mode 100644 site2/website/versioned_docs/version-2.4.1/admin-api-non-persistent-topics.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/admin-api-overview.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/admin-api-partitioned-topics.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/administration-dashboard.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/administration-upgrade.md
copy site2/{docs => website/versioned_docs/version-2.4.1}/client-libraries-java.md (90%)
copy site2/{docs => website/versioned_docs/version-2.4.1}/concepts-messaging.md (95%)
create mode 100644 site2/website/versioned_docs/version-2.4.1/concepts-tiered-storage.md
copy site2/{docs => website/versioned_docs/version-2.4.1}/cookbooks-compaction.md (97%)
create mode 100644 site2/website/versioned_docs/version-2.4.1/functions-api.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/functions-cli.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/functions-debug.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/functions-deploy.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/functions-develop.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/functions-overview-new.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/functions-overview.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/functions-runtime.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/getting-started-standalone.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/io-cdc-canal.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/io-cdc-debezium.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/io-connectors.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/io-debug.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/io-develop.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/io-jdbc.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/io-netty.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/io-use.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/reference-configuration.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/reference-connector-admin.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/reference-metrics.md
copy site2/{docs => website/versioned_docs/version-2.4.1}/reference-pulsar-admin.md (74%)
create mode 100644 site2/website/versioned_docs/version-2.4.1/schema-evolution-compatibility.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/schema-get-started.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/schema-manage.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/schema-understand.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/security-athenz.md
create mode 100644 site2/website/versioned_docs/version-2.4.1/security-authorization.md
copy site2/{docs => website/versioned_docs/version-2.4.1}/security-kerberos.md (56%)
create mode 100644 site2/website/versioned_docs/version-2.4.1/security-overview.md
copy site2/{docs => website/versioned_docs/version-2.4.1}/security-tls-authentication.md (55%)
create mode 100644 site2/website/versioned_docs/version-2.4.1/security-tls-transport.md
copy site2/{docs => website/versioned_docs/version-2.4.1}/security-token-client.md (80%)
create mode 100644 site2/website/versioned_sidebars/version-2.4.1-sidebars.json
create mode 100644 tests/docker-images/java-test-functions/src/main/java/org/apache/pulsar/tests/integration/io/TestStateSink.java
create mode 100644 tests/docker-images/java-test-functions/src/main/java/org/apache/pulsar/tests/integration/io/TestStateSource.java