This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch
dependabot/go_modules/pulsar-function-go/google.golang.org/protobuf-1.33.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from a137c475450 Bump google.golang.org/protobuf in /pulsar-function-go
add 63c0b47d720 [improve][pip] PIP-343: Use picocli instead of jcommander
(#22181)
add 9ace957faf9 [fix][ws] Check the validity of config before start
websocket service (#22231)
add 11569042011 [improve][broker] Add createTopicIfDoesNotExist option to
RawReader constructor (#22264)
add 37d88b8ff3e [improve][misc] Add mandatory checkbox about release
policy in the issue template (#22267)
add 434ec1b884b [improve][cli] PIP-343: Use picocli instead of jcommander
in pulsar-client-tools (#22209)
add ac263c0fdbc [fix][build] Add special handling for pulsar-bom in
set-project-version.sh (#22272)
add 95d24ac4550 [feat][client] Introduce Refresh API in the TableView
(#21417)
add 2ffcf62f628 [fix][sec] Upgrade Zookeeper to 3.9.2 to address
CVE-2024-23944 (#22275)
add 73dc213d4ce [fix][broker] upgrade jclouds 2.5.0 -> 2.6.0 (#22220)
add 999e39b0c7e [fix] Upgrade jose4j to 0.9.4 (#22273)
add 442595ea26c [fix][sec] Dismiss warning about MD5 since it's sufficient
for these use cases (#22282)
add 4e0c145c89a [fix][broker] Fix wrong double-checked locking for
readOnActiveConsumerTask in dispatcher (#22279)
add 96d77f7e1d5 [fix][broker] Avoid execute prepareInitPoliciesCacheAsync
if namespace is deleted (#22268)
add 34f8e0e9456 [improve] [broker] Support create RawReader based on
configuration (#22280)
add cd512e4da6a [improve][misc] Upgrade checkstyle to 10.14.2 (#22291)
add 0c9d8601698 [improve][misc] Upgrade jersey to 2.41 (#22290)
add 8dc9a9b1b4c [cleanup][meta] Remove com.beust.jcommander.internal
import (#22294)
add c616b35e039 [fix] [client] Unclear error message when creating a
consumer with two same topics (#22255)
add 1b1bd4b610d [improve][broker] Remove the atomicity on active consumer
of a dispatcher (#22285)
add 2803ba20ed4 [improve][broker] Add missing configuration keys for
caching catch-up reads (#22295)
add fd34d4ab9c5 [improve][broker] Add fine-grain authorization to ns/topic
management endpoints (#22305)
add 5cabcacbfa8 [improve][admin] Fix the `createMissingPartitions` doesn't
response correctly (#22311)
add 71598c11637 [fix][client]Fixed getting an incorrect `maxMessageSize`
value when accessing multiple clusters in the same process (#22306)
add 74585b5ae07 [improve][cli] CmdConsume print publishTime And eventTime
info. (#22308)
add 24e9437ce06 [improve][misc] Include native epoll library for Netty for
arm64 (#22319)
add 69c45ad5300 [improve][cli] PIP-343: Use picocli instead of jcommander
in pulsar-perf (#22303)
add d0ca9835cf9 [fix][broker] Create new ledger after the current ledger
is closed (#22034)
add 7644a027502 [improve][cli] PIP-343: Use picocli instead of jcommander
in bin/pulsar (#22288)
add 41e515caf24 [improve] PIP 342: Support OpenTelemetry metrics in Pulsar
client (#22178)
add 0b5d9ab854b [fix]Bump google.golang.org/protobuf from 1.32.0 to 1.33.0
in /pulsar-function-go/examples (#22262)
add 401d3ca807e Merge remote-tracking branch 'apache/master' into
dependabot/go_modules/pulsar-function-go/google.golang.org/protobuf-1.33.0
No new revisions were added by this update.
Summary of changes:
.github/ISSUE_TEMPLATE/bug-report.yml | 13 +-
buildtools/pom.xml | 2 +-
.../src/main/resources/pulsar/checkstyle.xml | 2 +-
conf/broker.conf | 12 +-
conf/standalone.conf | 4 +-
distribution/server/src/assemble/LICENSE.bin.txt | 32 +-
distribution/shell/src/assemble/LICENSE.bin.txt | 18 +-
distribution/shell/src/assemble/NOTICE.bin.txt | 3 +
jclouds-shaded/pom.xml | 78 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 2 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 22 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 33 +-
.../mledger/impl/ManagedLedgerFactoryTest.java | 2 +-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 111 +-
.../mledger/impl/NonDurableCursorTest.java | 17 +-
.../mledger/impl/ShadowManagedLedgerImplTest.java | 5 +-
pip/pip-342 OTel client metrics support.md | 168 ++
pip/pip-343.md | 143 ++
pom.xml | 28 +-
.../authorization/PulsarAuthorizationProvider.java | 1 +
pulsar-broker/pom.xml | 4 +-
.../org/apache/pulsar/PulsarBrokerStarter.java | 135 +-
.../apache/pulsar/PulsarClusterMetadataSetup.java | 88 +-
.../pulsar/PulsarClusterMetadataTeardown.java | 32 +-
.../apache/pulsar/PulsarInitialNamespaceSetup.java | 33 +-
.../java/org/apache/pulsar/PulsarStandalone.java | 39 +-
.../org/apache/pulsar/PulsarStandaloneStarter.java | 18 +-
.../PulsarTransactionCoordinatorMetadataSetup.java | 32 +-
.../org/apache/pulsar/PulsarVersionStarter.java | 22 +-
.../apache/pulsar/broker/admin/AdminResource.java | 7 +-
.../pulsar/broker/admin/impl/NamespacesBase.java | 166 +-
.../broker/admin/impl/PersistentTopicsBase.java | 176 +-
.../AbstractDispatcherSingleActiveConsumer.java | 30 +-
.../SystemTopicBasedTopicPoliciesService.java | 66 +-
...onPersistentDispatcherSingleActiveConsumer.java | 4 +-
.../PersistentDispatcherSingleActiveConsumer.java | 36 +-
.../broker/service/persistent/PersistentTopic.java | 4 +-
.../org/apache/pulsar/broker/tools/BrokerTool.java | 34 +-
.../pulsar/broker/tools/GenerateDocsCommand.java | 61 +-
.../pulsar/broker/tools/LoadReportCommand.java | 78 +-
.../org/apache/pulsar/client/api/RawReader.java | 19 +-
.../apache/pulsar/client/impl/RawReaderImpl.java | 18 +-
.../org/apache/pulsar/compaction/Compactor.java | 2 +-
.../apache/pulsar/compaction/CompactorTool.java | 27 +-
.../pulsar/utils/auth/tokens/TokensCliUtils.java | 211 ++-
.../org/apache/pulsar/PulsarBrokerStarterTest.java | 109 +-
.../pulsar/PulsarClusterMetadataSetupTest.java | 12 +-
.../pulsar/PulsarClusterMetadataTeardownTest.java | 6 +-
.../pulsar/PulsarInitialNamespaceSetupTest.java | 6 +-
...sarTransactionCoordinatorMetadataSetupTest.java | 6 +-
.../apache/pulsar/PulsarVersionStarterTest.java | 6 +-
.../pulsar/broker/admin/NamespaceAuthZTest.java | 163 ++
.../pulsar/broker/admin/PersistentTopicsTest.java | 7 +
.../apache/pulsar/broker/admin/TopicAuthZTest.java | 345 ++++
.../broker/service/BacklogQuotaManagerTest.java | 13 +-
.../broker/service/BrokerBkEnsemblesTests.java | 12 +-
.../broker/service/BrokerBookieIsolationTest.java | 112 +-
.../broker/service/ConsumedLedgersTrimTest.java | 6 +-
.../SystemTopicBasedTopicPoliciesServiceTest.java | 19 +
.../apache/pulsar/broker/tools/BrokerToolTest.java | 8 +-
.../pulsar/client/api/MultiTopicsConsumerTest.java | 27 +
.../client/api/SimpleProducerConsumerTest.java | 6 +-
.../client/impl/ProducerConsumerInternalTest.java | 44 +
.../client/impl/ProducerMemoryLimitTest.java | 12 +-
.../pulsar/client/impl/ProducerSemaphoreTest.java | 18 +-
.../apache/pulsar/client/impl/RawReaderTest.java | 62 +-
.../apache/pulsar/client/impl/TableViewTest.java | 134 +-
.../pulsar/compaction/CompactorToolTest.java | 6 +-
.../utils/auth/tokens/TokensCliUtilsTest.java | 8 +-
pulsar-cli-utils/pom.xml | 6 +-
.../org/apache/pulsar/cli/ValueValidationUtil.java | 11 +-
.../cli/converters/ByteUnitToLongConverter.java | 39 -
.../apache/pulsar/cli/converters/ByteUnitUtil.java | 7 +-
.../cli/converters/TimeUnitToMillisConverter.java | 42 -
.../ByteUnitToIntegerConverter.java} | 28 +-
.../picocli/ByteUnitToLongConverter.java | 21 +-
.../picocli/TimeUnitToMillisConverter.java | 22 +-
.../picocli/TimeUnitToSecondsConverter.java | 22 +-
.../cli/converters/picocli}/package-info.java | 2 +-
.../apache/pulsar/cli/ValueValidationUtilTest.java | 21 +-
.../pulsar/cli/converters/ByteConversionTest.java | 31 +-
.../pulsar/cli/converters/TimeConversionTest.java | 10 +-
.../cli/validators/CliUtilValidatorsTest.java | 15 +-
.../org/apache/pulsar/client/api/TableView.java | 34 +
.../pulsar/client/impl/crypto/MessageCryptoBc.java | 2 +-
.../apache/pulsar/admin/cli/CmdFunctionsTest.java | 114 +-
.../pulsar/admin/cli/DeprecatedCommanderTest.java | 84 -
.../pulsar/admin/cli/PulsarAdminToolTest.java | 77 +-
.../org/apache/pulsar/client/cli/DocumentTest.java | 20 +-
.../client/cli/PulsarClientToolForceBatchNum.java | 7 +-
.../pulsar/client/cli/PulsarClientToolTest.java | 7 +-
pulsar-client-tools/pom.xml | 9 +-
.../org/apache/pulsar/admin/cli/CliCommand.java | 115 +-
.../java/org/apache/pulsar/admin/cli/CmdBase.java | 117 +-
.../org/apache/pulsar/admin/cli/CmdBookies.java | 39 +-
.../apache/pulsar/admin/cli/CmdBrokerStats.java | 40 +-
.../org/apache/pulsar/admin/cli/CmdBrokers.java | 84 +-
.../org/apache/pulsar/admin/cli/CmdClusters.java | 281 ++-
.../apache/pulsar/admin/cli/CmdFunctionWorker.java | 28 +-
.../org/apache/pulsar/admin/cli/CmdFunctions.java | 391 ++--
.../pulsar/admin/cli/CmdGenerateDocument.java | 121 +-
.../admin/cli/CmdNamespaceIsolationPolicy.java | 100 +-
.../org/apache/pulsar/admin/cli/CmdNamespaces.java | 1686 +++++++++--------
.../pulsar/admin/cli/CmdNonPersistentTopics.java | 81 +-
.../org/apache/pulsar/admin/cli/CmdPackages.java | 72 +-
.../pulsar/admin/cli/CmdPersistentTopics.java | 409 +++--
.../org/apache/pulsar/admin/cli/CmdProxyStats.java | 18 +-
.../apache/pulsar/admin/cli/CmdResourceGroups.java | 74 +-
.../apache/pulsar/admin/cli/CmdResourceQuotas.java | 65 +-
.../org/apache/pulsar/admin/cli/CmdSchemas.java | 78 +-
.../java/org/apache/pulsar/admin/cli/CmdSinks.java | 210 +--
.../org/apache/pulsar/admin/cli/CmdSources.java | 180 +-
.../org/apache/pulsar/admin/cli/CmdTenants.java | 76 +-
.../apache/pulsar/admin/cli/CmdTopicPolicies.java | 1223 ++++++-------
.../org/apache/pulsar/admin/cli/CmdTopics.java | 1934 +++++++++-----------
.../apache/pulsar/admin/cli/CmdTransactions.java | 130 +-
.../apache/pulsar/admin/cli/CmdUsageFormatter.java | 88 -
.../pulsar/admin/cli/CustomCommandsUtils.java | 54 +-
.../admin/cli/PulsarAdminPropertiesProvider.java | 49 +
.../pulsar/admin/cli/PulsarAdminSupplier.java | 7 +-
.../apache/pulsar/admin/cli/PulsarAdminTool.java | 203 +-
...ackage-info.java => PulsarVersionProvider.java} | 10 +
.../cli/{package-info.java => AbstractCmd.java} | 12 +
.../pulsar/client/cli/AbstractCmdConsume.java | 5 +-
.../org/apache/pulsar/client/cli/CmdConsume.java | 68 +-
.../client/cli/CmdGenerateDocumentation.java | 79 +-
.../org/apache/pulsar/client/cli/CmdProduce.java | 75 +-
.../java/org/apache/pulsar/client/cli/CmdRead.java | 44 +-
...NoSplitter.java => ProxyProtocolConverter.java} | 25 +-
.../client/cli/PulsarClientPropertiesProvider.java | 54 +
.../apache/pulsar/client/cli/PulsarClientTool.java | 237 +--
...ackage-info.java => PulsarVersionProvider.java} | 10 +
.../pulsar/internal/CommandDescriptionUtil.java | 29 +-
.../org/apache/pulsar/internal/CommandHook.java | 16 +-
.../apache/pulsar/internal/CommanderFactory.java | 91 +
.../apache/pulsar/internal/InnerClassFactory.java | 60 +
.../{shell => internal}/ShellCommandsProvider.java | 35 +-
.../org/apache/pulsar/internal}/package-info.java | 2 +-
.../java/org/apache/pulsar/shell/AdminShell.java | 33 +-
.../java/org/apache/pulsar/shell/ClientShell.java | 32 +-
.../java/org/apache/pulsar/shell/ConfigShell.java | 194 +-
.../apache/pulsar/shell/JCommanderCompleter.java | 203 --
.../shell/OptionStrictArgumentCompleter.java | 109 --
.../java/org/apache/pulsar/shell/PulsarShell.java | 140 +-
.../apache/pulsar/admin/cli/TestCmdClusters.java | 40 +-
.../org/apache/pulsar/admin/cli/TestCmdSinks.java | 10 +-
.../apache/pulsar/admin/cli/TestCmdSources.java | 22 +-
.../org/apache/pulsar/admin/cli/TestCmdTopics.java | 36 +-
.../org/apache/pulsar/shell/AdminShellTest.java | 16 +-
.../org/apache/pulsar/shell/ConfigShellTest.java | 122 +-
.../pulsar/shell/JCommanderCompleterTest.java | 53 -
.../org/apache/pulsar/shell/PulsarShellTest.java | 25 +-
.../client/impl/AbstractBatchMessageContainer.java | 9 +-
.../client/impl/BatchMessageContainerImpl.java | 10 +-
.../org/apache/pulsar/client/impl/ClientCnx.java | 3 +-
.../pulsar/client/impl/ConnectionHandler.java | 7 +
.../apache/pulsar/client/impl/ConsumerImpl.java | 3 +-
.../client/impl/MultiTopicsConsumerImpl.java | 21 +-
.../apache/pulsar/client/impl/ProducerImpl.java | 38 +-
.../apache/pulsar/client/impl/TableViewImpl.java | 141 +-
pulsar-common/pom.xml | 6 +
.../org/apache/pulsar/common/nar/NarUnpacker.java | 1 +
.../apache/pulsar/common/tls/InetAddressUtils.java | 16 +-
.../common/util/collections/LongPairSet.java | 4 +-
pulsar-docs-tools/pom.xml | 4 +-
.../docs/tools/BaseGenerateDocumentation.java | 50 +-
.../apache/pulsar/docs/tools/CmdGenerateDocs.java | 171 +-
.../pulsar/docs/tools/CmdGenerateDocsTest.java | 96 +-
pulsar-function-go/examples/go.mod | 2 +-
pulsar-function-go/examples/go.sum | 4 +-
.../functions/worker/FunctionWorkerStarter.java | 25 +-
.../worker/FunctionWorkerStarterTest.java | 6 +-
pulsar-io/docs/pom.xml | 4 +-
.../replication/AuditorBookieCheckTaskTest.java | 10 +-
pulsar-proxy/pom.xml | 4 +-
.../pulsar/proxy/server/ProxyServiceStarter.java | 34 +-
pulsar-testclient/pom.xml | 4 +-
.../proxy/socket/client/PerformanceClient.java | 65 +-
.../apache/pulsar/testclient/BrokerMonitor.java | 30 +-
.../testclient/CmdGenerateDocumentation.java | 67 +-
.../pulsar/testclient/LoadSimulationClient.java | 34 +-
.../testclient/LoadSimulationController.java | 68 +-
.../pulsar/testclient/ManagedLedgerWriter.java | 57 +-
.../testclient/PerformanceBaseArguments.java | 59 +-
.../pulsar/testclient/PerformanceConsumer.java | 65 +-
.../pulsar/testclient/PerformanceProducer.java | 96 +-
.../pulsar/testclient/PerformanceReader.java | 19 +-
.../testclient/PerformanceTopicListArguments.java | 10 +-
.../pulsar/testclient/PerformanceTransaction.java | 45 +-
...or.java => PositiveNumberParameterConvert.java} | 15 +-
.../pulsar/testclient/GenerateDocumentionTest.java | 37 +
.../apache/pulsar/websocket/ProducerHandler.java | 14 +-
.../websocket/service/WebSocketServiceStarter.java | 37 +-
.../service/WebSocketServiceStarterTest.java | 6 +-
src/set-project-version.sh | 1 +
.../pulsar/tests/integration/cli/CLITest.java | 9 +-
.../tests/integration/cli/ClientToolTest.java | 7 +-
197 files changed, 7852 insertions(+), 7218 deletions(-)
create mode 100644 pip/pip-342 OTel client metrics support.md
create mode 100644 pip/pip-343.md
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespaceAuthZTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicAuthZTest.java
delete mode 100644
pulsar-cli-utils/src/main/java/org/apache/pulsar/cli/converters/ByteUnitToLongConverter.java
delete mode 100644
pulsar-cli-utils/src/main/java/org/apache/pulsar/cli/converters/TimeUnitToMillisConverter.java
rename
pulsar-cli-utils/src/main/java/org/apache/pulsar/cli/converters/{ByteUnitIntegerConverter.java
=> picocli/ByteUnitToIntegerConverter.java} (60%)
copy
pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/AutoSchemaFunction.java
=>
pulsar-cli-utils/src/main/java/org/apache/pulsar/cli/converters/picocli/ByteUnitToLongConverter.java
(66%)
copy
pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/AutoSchemaFunction.java
=>
pulsar-cli-utils/src/main/java/org/apache/pulsar/cli/converters/picocli/TimeUnitToMillisConverter.java
(63%)
copy
pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/AutoSchemaFunction.java
=>
pulsar-cli-utils/src/main/java/org/apache/pulsar/cli/converters/picocli/TimeUnitToSecondsConverter.java
(62%)
copy {jclouds-shaded/src/main/java/org/apache/pulsar/jclouds =>
pulsar-cli-utils/src/main/java/org/apache/pulsar/cli/converters/picocli}/package-info.java
(94%)
delete mode 100644
pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/DeprecatedCommanderTest.java
delete mode 100644
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdUsageFormatter.java
create mode 100644
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/PulsarAdminPropertiesProvider.java
copy
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/{package-info.java
=> PulsarVersionProvider.java} (72%)
copy
pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/{package-info.java
=> AbstractCmd.java} (76%)
rename
pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/{NoSplitter.java
=> ProxyProtocolConverter.java} (63%)
create mode 100644
pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/PulsarClientPropertiesProvider.java
copy
pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/{package-info.java
=> PulsarVersionProvider.java} (73%)
copy
pulsar-io/azure-data-explorer/src/main/java/org/apache/pulsar/io/azuredataexplorer/ADXSinkUtils.java
=>
pulsar-client-tools/src/main/java/org/apache/pulsar/internal/CommandDescriptionUtil.java
(56%)
copy
pulsar-broker-common/src/main/java/org/apache/pulsar/common/configuration/PropertiesContext.java
=>
pulsar-client-tools/src/main/java/org/apache/pulsar/internal/CommandHook.java
(70%)
create mode 100644
pulsar-client-tools/src/main/java/org/apache/pulsar/internal/CommanderFactory.java
create mode 100644
pulsar-client-tools/src/main/java/org/apache/pulsar/internal/InnerClassFactory.java
rename pulsar-client-tools/src/main/java/org/apache/pulsar/{shell =>
internal}/ShellCommandsProvider.java (58%)
copy {jclouds-shaded/src/main/java/org/apache/pulsar/jclouds =>
pulsar-client-tools/src/main/java/org/apache/pulsar/internal}/package-info.java
(95%)
delete mode 100644
pulsar-client-tools/src/main/java/org/apache/pulsar/shell/JCommanderCompleter.java
delete mode 100644
pulsar-client-tools/src/main/java/org/apache/pulsar/shell/OptionStrictArgumentCompleter.java
delete mode 100644
pulsar-client-tools/src/test/java/org/apache/pulsar/shell/JCommanderCompleterTest.java
rename
pulsar-testclient/src/main/java/org/apache/pulsar/testclient/{PositiveNumberParameterValidator.java
=> PositiveNumberParameterConvert.java} (68%)
