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/grpc-1.56.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 71456851bc2 Merge remote-tracking branch 'origin/master' into
dependabot/go_modules/pulsar-function-go/google.golang.org/grpc-1.56.3
add 720d6d24327 [fix][broker] Fix failure while creating non-durable
cursor with inactive managed-ledger (#21508)
add e4a25156c7e [improve][broker] PIP-307 Added assignedBrokerUrl to
CloseProducerCmd to skip lookups upon producer reconnections during unloading
add 6018b2bf8c0 Resolved comments
add c0eec1e46ed resolved comments
add c30eae1296d resolved comment
add 922525f5539 [improve][misc] Disable rebase and merge to prevent
unsquashed PRs (#21517)
add e5af0979bca [improve][pip] PIP-300: Add custom dynamic configuration
for plugins (#21127)
add 957337bc02a [fix][client] Avert extensive time consumption during
table view construction (#21270)
add eebd821e00a [improve][ws] Support subscribing multi/pattern topic for
Websocket (#21379)
add 44abba9922e [improve][build] Change UBUNTU_MIRROR default value
(#21520)
add 469ce7e1048 [fix][test] Fix ExtensibleLoadManagerImplTest flaky test
(#21479)
add f5814176efc [fix][txn] Ack all message ids when ack chunk messages
with transaction. (#21268)
add 428c18c8d0c [fix][broker] Fix namespace bundle stuck in unloading
status (#21445)
add 51202a68895 [fix][test] Fix multiple thread leaks in tests, part 3
(#21543)
add f607313351a [improve][ci] Disable stale bot (#21549)
add 3c067ce2802 [fix][broker] Fix create topic with different auto
creation strategies causes race condition (#21545)
add 2efef87e5d9 [fix][broker] Fix the deadlock when using
BookieRackAffinityMapping with rackaware policy (#21481)
add a8f22d85a19 [fix][ml] Fix unfinished callback when deleting managed
ledger (#21530)
add 77cd942f51e [fix][test] Fix that some test cases are not running as
expected on CI (#21532)
add 08067451c0d [fix][client] Fix print error log 'Auto getting partitions
failed' when expend partition. (#21485)
add d78db658ece [fix] [bk-config] Format bk config (#21523)
add e7536a2a405 [fix] [ml] Fix orphan scheduled task for ledger create
timeout check (#21542)
add ea1fc0f2013 [fix] [broker] Fix thousands orphan PersistentTopic caused
OOM (#21540)
add b949187e646 [fix][broker] Fix setReplicatedSubscriptionStatus
incorrect behavior (#21510)
add 62afe0194e0 [fix][docs] Update deploy-kubernetes url (#21558)
add 0a173869597 [improve][test] Use BrokerInterceptors to load
CounterBrokerInterceptor (#21519)
add 6115a1ee5c1 [improve][pip] PIP-318: Don't retain null-key messages
during topic compaction (#21541)
add 36d4708356d [improve][cli][PIP-280] Retrofit `pulsar-cli-utils` into
`pulsar-broker` and `pulsar-client-tools` (#21412)
add 2322004069f [fix][broker] Do not write replicated snapshot marker when
the topic which is not enable replication (#21495)
add 403faa4c778 [fix][broker] Fix resource_quota_zpath (#21461)
add cbdb19c2fd7 [improve][pip] PIP-312: Use StateStoreProvider to manage
state in Pulsar Functions endpoints (#21438)
add e1318b2c1e6 [improve][broker][PIP-318] Support not retaining null-key
message during topic compaction (#21578)
add 9fbb92a69b5 [improve][pip] PIP-303: Add optional parameters for
getPartitionedStats (#21228)
add 2cb54f3d858 [fix][test] Detects whether an empty object is returned,
prevent NPE exception (#21585)
add 98bf9dd7291 [fix][broker] Duplicate LedgerOffloader creation when
namespace/topic… (#21591)
add b2f2b53907e [fix] [broker] Delete topic timeout due to NPE (#21595)
add c87cfb3f50b [improve] [client] Add producerName for deadLetterProducer
(#21589)
add d1b7d0b7d86 [fix][broker] Correct schema deletion for parititioned
topic (#21574)
add 2a5aa44338f [fix][test] Fix flaky test
ManagedLedgerTest#testManagedLedgerRollOverIfFull (#21609)
add 5229a73fea6 [improve][client] Ignore InterruptedException when
pulsar-perf finishing (#21613)
add c1a1a8ddebe [cleanup][client] Fix inconsistent API annotations of
`getTopicName` (#21620)
add 697c1680b99 [fix][sec] Upgrade rabbitmq client to address
CVE-2023-46120 (#21619)
add 8dac8a5dbfb [improve][doc] Clarify to check numbering when creating
the PIP doc (#21623)
add e1d06b5f54f [improve][sec] Support for Elliptic Curve Cryptography
(EC, ECC) (certificates/private keys) (#21621)
add 1a024bc6aa0 [fix] [log] fix the vague response if topic not found
(#20932)
add 5572c38cab3 [improve][build] Upgrade Apache ZooKeeper to 3.9.1 (#20933)
add e820f90c925 [improve][sec] Align the default mechanism for server to
request certificates (#21625)
add 81a9a527b35 [fix][broker] Fixed getting incorrect KeyValue schema
version (#21632)
add 93ed61bf9bf [fix][test] Fix flaky test
SimpleProducerConsumerStatTest#testPartitionTopicStats (#21642)
add 5c89188d488 [fix][client] Fix some typos in client module (#21416)
add 4e7bff7f1d2 [improve][sec] Delete announced deprecate method. (#21637)
add e27070afffb [fix][admin] Fix KeyValue schema compatibility check
caused OOM (#21645)
add 7508700f53d [fix][broker] Fix incorrect unack count when using shared
subscription on non-persistent topic (#21592)
add 3377003dbe0 [improve] Make `sslTruststorePassword` sensitive for the
Kafka connector config (#21639)
add a832d29e0eb [improve][broker] Add optional parameters for
getPartitionedStats (#21611)
add 575a4840fcb [improve][pip] PIP-315: Configurable max delay limit for
delayed delivery (#21490)
add 2bf13547bf4 [fix][test] Fix the bug caused by unload topic and
compaction task failure after task is triggered (#21634)
add f3fb4131248 [improve][admin] Add clusters check when set replication
clusters (#21650)
add d5457d35a68 [fix][broker] Fix memory leak during topic compaction
(#21647)
add 9872daab50b [fix][build] Fix Stage Docker images fail on M1 Mac
(#21659)
add 991a95421b4 [fix][broker] Fix lookupRequestSemaphore leak when topic
not found (#21646)
add 5b19cf30957 [improve][pip] PIP-312: Use StateStoreProvider to manage
state in Pulsar Functions endpoints (#21597)
add aa3fcc905a7 [improve][broker] Print recoverBucketSnapshot log if
cursorProperties are empty (#21651)
add 03000195929 [improve] [bookie] Enable reorder read sequence for bk
client by default (#21652)
add 15b655cfea3 [improve][sec] Align some namespace level policy
authorisation check (#21640)
add 5482c78a35a Merge remote-tracking branch 'apache/master' into
dependabot/go_modules/pulsar-function-go/google.golang.org/grpc-1.56.3
add 67624e6f3ed Updated required Go version
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 2 +-
.github/workflows/ci-stale-issue-pr.yaml | 17 -
build/pulsar_ci_tool.sh | 26 +-
conf/bookkeeper.conf | 13 +-
conf/broker.conf | 5 +-
conf/standalone.conf | 5 +-
deployment/kubernetes/README.md | 2 +-
distribution/server/pom.xml | 6 +
distribution/server/src/assemble/LICENSE.bin.txt | 9 +-
docker/pulsar/Dockerfile | 4 +-
docker/pulsar/pom.xml | 2 +-
managed-ledger/pom.xml | 6 +
.../apache/bookkeeper/mledger/ManagedLedger.java | 4 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 2 +-
.../mledger/impl/ManagedLedgerFactoryImpl.java | 5 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 36 +-
.../impl/ManagedLedgerFactoryShutdownTest.java | 2 +
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 84 +++-
pip/README.md | 1 +
pip/pip-300.md | 73 ++++
pip/pip-303.md | 224 +++++++++++
pip/pip-312.md | 150 ++++++++
pip/pip-315.md | 137 +++++++
pip/pip-318.md | 49 +++
pom.xml | 14 +-
.../authentication/AuthenticationProviderSasl.java | 4 +
.../authentication/SaslAuthenticateTest.java | 44 +--
.../rackawareness/BookieRackAffinityMapping.java | 9 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 8 +-
.../authorization/AuthorizationProvider.java | 101 -----
.../BookieRackAffinityMappingTest.java | 68 ++++
.../jetty/tls/JettySslContextFactoryTest.java | 13 +-
.../JettySslContextFactoryWithKeyStoreTest.java | 13 +-
pulsar-broker/pom.xml | 6 +
.../org/apache/pulsar/broker/PulsarService.java | 6 +
.../pulsar/broker/admin/impl/NamespacesBase.java | 34 +-
.../broker/admin/impl/PersistentTopicsBase.java | 32 +-
.../broker/admin/impl/SchemasResourceBase.java | 16 +-
.../pulsar/broker/admin/impl/TransactionsBase.java | 6 +-
.../broker/admin/v1/NonPersistentTopics.java | 5 +-
.../pulsar/broker/admin/v1/PersistentTopics.java | 8 +-
.../apache/pulsar/broker/admin/v2/Namespaces.java | 3 +-
.../broker/admin/v2/NonPersistentTopics.java | 20 +-
.../pulsar/broker/admin/v2/PersistentTopics.java | 23 +-
.../BucketDelayedDeliveryTrackerFactory.java | 4 +
.../bucket/BucketDelayedDeliveryTracker.java | 9 +-
.../extensions/ExtensibleLoadManagerImpl.java | 49 +++
.../channel/ServiceUnitStateChannel.java | 10 +
.../channel/ServiceUnitStateChannelImpl.java | 63 ++-
.../loadbalance/impl/ModularLoadManagerImpl.java | 2 +-
.../pulsar/broker/lookup/TopicLookupBase.java | 11 +-
.../pulsar/broker/namespace/OwnedBundle.java | 2 +-
.../pulsar/broker/service/AbstractTopic.java | 5 +
.../pulsar/broker/service/BrokerService.java | 428 +++++++++++----------
.../org/apache/pulsar/broker/service/Consumer.java | 7 +-
.../pulsar/broker/service}/GetStatsOptions.java | 14 +-
.../org/apache/pulsar/broker/service/Producer.java | 9 +-
.../apache/pulsar/broker/service/ServerCnx.java | 48 ++-
.../SystemTopicBasedTopicPoliciesService.java | 19 +-
.../org/apache/pulsar/broker/service/Topic.java | 9 +
.../apache/pulsar/broker/service/TransportCnx.java | 3 +
.../nonpersistent/NonPersistentSubscription.java | 7 +-
.../service/nonpersistent/NonPersistentTopic.java | 52 ++-
.../service/persistent/PersistentSubscription.java | 21 +-
.../broker/service/persistent/PersistentTopic.java | 81 +++-
.../pulsar/client/impl/RawBatchConverter.java | 25 +-
.../pulsar/compaction/TwoPhaseCompactor.java | 31 +-
.../pulsar/utils/auth/tokens/TokensCliUtils.java | 23 +-
....java => MangedLedgerInterceptorImpl2Test.java} | 4 +-
.../apache/pulsar/broker/admin/AdminApi2Test.java | 17 +-
.../broker/admin/AdminApiGetLastMessageIdTest.java | 2 +-
.../apache/pulsar/broker/admin/AdminApiTest.java | 84 ++++
.../apache/pulsar/broker/admin/NamespacesTest.java | 9 +
.../pulsar/broker/admin/PersistentTopicsTest.java | 8 +-
.../pulsar/broker/admin/TopicAutoCreationTest.java | 65 +++-
.../pulsar/broker/admin/TopicPoliciesTest.java | 5 +
.../broker/admin/v3/AdminApiTransactionTest.java | 20 +-
.../broker/auth/MockAuthorizationProvider.java | 37 --
.../broker/intercept/BrokerInterceptorTest.java | 101 +++--
.../broker/intercept/CounterBrokerInterceptor.java | 1 +
.../extensions/ExtensibleLoadManagerImplTest.java | 191 +++++++--
.../channel/ServiceUnitStateChannelTest.java | 1 +
.../impl/ModularLoadManagerImplTest.java | 52 +++
.../broker/namespace/NamespaceUnloadingTest.java | 29 ++
.../broker/namespace/OwnershipCacheTest.java | 2 +-
.../pulsar/broker/service/BatchMessageTest.java | 1 +
.../pulsar/broker/service/BrokerServiceTest.java | 4 +-
.../pulsar/broker/service/PersistentTopicTest.java | 6 +-
.../broker/service/ReplicatorSubscriptionTest.java | 235 +++++++++++
.../pulsar/broker/service/ReplicatorTestBase.java | 58 ++-
.../SystemTopicBasedTopicPoliciesServiceTest.java | 29 --
.../apache/pulsar/broker/service/TopicGCTest.java | 112 ++++++
.../persistent/BucketDelayedDeliveryTest.java | 123 ++++++
.../service/persistent/PersistentTopicTest.java | 3 +-
.../broker/service/schema/SchemaServiceTest.java | 37 ++
.../broker/service/schema/TopicSchemaTest.java | 118 ++++++
.../pulsar/broker/stats/ConsumerStatsTest.java | 33 ++
.../broker/transaction/TransactionConsumeTest.java | 46 +++
.../api/AuthorizationProducerConsumerTest.java | 32 --
.../pulsar/client/api/DeadLetterTopicTest.java | 59 +++
.../client/api/OrphanPersistentTopicTest.java | 154 ++++++++
...roducerConsumerDisallowAutoCreateTopicTest.java | 79 ++++
.../client/api/SimpleProducerConsumerStatTest.java | 6 +-
.../impl/PatternTopicsConsumerImplAuthTest.java | 38 --
.../apache/pulsar/client/impl/TableViewTest.java | 60 +++
.../apache/pulsar/compaction/CompactionTest.java | 79 ++--
.../worker/PulsarFunctionLocalRunTest.java | 34 +-
...TestUtils.java => TestPulsarFunctionUtils.java} | 3 +-
.../apache/pulsar/io/PulsarBatchSourceE2ETest.java | 8 +-
.../apache/pulsar/io/PulsarFunctionE2ETest.java | 12 +-
.../org/apache/pulsar/io/PulsarSinkE2ETest.java | 18 +-
.../org/apache/pulsar/io/PulsarSourceE2ETest.java | 8 +-
.../security/tls/MockedPulsarStandalone.java | 179 +++++++++
.../tls/ec/TlsWithECCertificateFileTest.java | 109 ++++++
.../security/tls/ec/TlsWithECKeyStoreTest.java | 121 ++++++
.../websocket/proxy/ProxyPublishConsumeTest.java | 68 ++++
.../pulsar/client/admin/GetStatsOptions.java | 12 +
.../org/apache/pulsar/client/admin/Topics.java | 19 +-
.../pulsar/client/admin/internal/TopicsImpl.java | 84 ++--
.../client/impl/auth/AuthenticationSasl.java | 6 +
.../pulsar/client/cli/PulsarClientToolTest.java | 3 +
.../pulsar/admin/cli/CmdPersistentTopics.java | 25 +-
.../apache/pulsar/admin/cli/CmdTransactions.java | 18 +-
.../org/apache/pulsar/client/impl/ClientCnx.java | 30 +-
.../pulsar/client/impl/ConnectionHandler.java | 21 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 91 ++++-
.../pulsar/client/impl/HttpLookupService.java | 21 +-
.../apache/pulsar/client/impl/Murmur3Hash32.java | 2 +-
.../client/impl/PartitionedProducerImpl.java | 2 +-
.../apache/pulsar/client/impl/TableViewImpl.java | 28 +-
.../pulsar/client/impl/TopicMessageImpl.java | 2 +-
.../client/impl/PartitionedProducerImplTest.java | 41 +-
.../pulsar/client/impl/schema/SchemaUtils.java | 3 +-
.../common/policies/data/OffloadPoliciesImpl.java | 96 ++---
.../apache/pulsar/common/protocol/Commands.java | 26 +-
.../pulsar/common/sasl/TGTRefreshThread.java | 2 +-
.../apache/pulsar/common/util/SecurityUtility.java | 34 +-
.../util/keystoretls/KeyStoreSSLContext.java | 6 +-
pulsar-common/src/main/proto/PulsarApi.proto | 2 +
.../common/policies/data/OffloadPoliciesTest.java | 31 +-
pulsar-function-go/go.mod | 8 +-
pulsar-function-go/go.sum | 282 ++++++++++++++
.../functions/instance/JavaInstanceRunnable.java | 2 +-
.../instance/state/BKStateStoreProviderImpl.java | 26 +-
.../PulsarMetadataStateStoreProviderImpl.java | 10 +-
.../instance/state/StateStoreProvider.java | 19 +
.../instance/JavaInstanceRunnableTest.java | 35 +-
.../windowing/WaterMarkEventGeneratorTest.java | 2 +-
.../functions/worker/PulsarWorkerService.java | 31 +-
.../functions/worker/rest/api/ComponentImpl.java | 153 +++-----
.../worker/FunctionRuntimeManagerTest.java | 14 +-
.../functions/worker/MembershipManagerTest.java | 5 +
.../functions/worker/SchedulerManagerTest.java | 1 +
.../apache/pulsar/io/kafka/KafkaSinkConfig.java | 3 +-
.../apache/pulsar/io/kafka/KafkaSourceConfig.java | 3 +-
.../org/apache/pulsar/metadata/TestZKServer.java | 151 ++++----
.../bookkeeper/PulsarRegistrationClientTest.java | 1 +
.../bookkeeper-storage/pom.xml | 6 +
.../pulsar/proxy/server/ProxyServiceStarter.java | 6 +
...Auth.java => ProxyKeyStoreTlsWithAuthTest.java} | 2 +-
...h.java => ProxyKeyStoreTlsWithoutAuthTest.java} | 2 +-
...TestWithAuth.java => ProxyTlsWithAuthTest.java} | 2 +-
pulsar-sql/presto-distribution/LICENSE | 6 +-
.../testclient/LoadSimulationController.java | 2 +-
.../pulsar/testclient/PerformanceProducer.java | 2 -
.../pulsar/testclient/PerformanceTransaction.java | 303 +++++++--------
.../pulsar/testclient/PerformanceProducerTest.java | 8 +-
.../MLTransactionMetadataStoreTest.java | 53 ++-
.../pulsar/websocket/AbstractWebSocketHandler.java | 8 +-
.../apache/pulsar/websocket/ConsumerHandler.java | 23 +-
.../websocket/MultiTopicConsumerHandler.java | 119 ++++++
.../WebSocketMultiTopicConsumerServlet.java | 45 +++
.../websocket/service/WebSocketServiceStarter.java | 3 +
.../src/main/resources/findbugsExclude.xml | 5 +
.../websocket/AbstractWebSocketHandlerTest.java | 26 +-
.../pulsar/websocket/PingPongSupportTest.java | 11 +-
.../java/org/apache/zookeeper/MockZooKeeper.java | 14 +-
.../ec/broker_client.cert.pem | 9 +
.../certificate-authority/ec/broker_client.csr.pem | 7 +
.../ec/broker_client.key-pk8.pem | 5 +
.../certificate-authority/ec/broker_client.key.pem | 8 +
tests/certificate-authority/ec/ca.cert.pem | 10 +
tests/certificate-authority/ec/ca.cert.srl | 1 +
tests/certificate-authority/ec/ca.key.pem | 8 +
.../ec/certificate_generation.txt | 34 ++
tests/certificate-authority/ec/client.cert.pem | 8 +
tests/certificate-authority/ec/client.csr.pem | 7 +
tests/certificate-authority/ec/client.key-pk8.pem | 5 +
tests/certificate-authority/ec/client.key.pem | 8 +
.../ec/jks/broker_client.cert.pem | 10 +
.../ec/jks/broker_client.keystore.jks | Bin 0 -> 2034 bytes
.../ec/jks/broker_client.signed.cert.pem | 11 +
tests/certificate-authority/ec/jks/ca.cert.pem | 10 +
tests/certificate-authority/ec/jks/ca.cert.srl | 1 +
tests/certificate-authority/ec/jks/ca.key.pem | 8 +
.../certificate-authority/ec/jks/ca.truststore.jks | Bin 0 -> 742 bytes
tests/certificate-authority/ec/jks/client.cert.pem | 10 +
.../ec/jks/client.keystore.jks | Bin 0 -> 1988 bytes
.../ec/jks/client.signed.cert.pem | 10 +
.../ec/jks/key_store_generation.txt | 33 ++
tests/certificate-authority/ec/jks/server.cert.pem | 10 +
.../ec/jks/server.keystore.jks | Bin 0 -> 2004 bytes
.../ec/jks/server.signed.cert.pem | 10 +
tests/certificate-authority/ec/server.cert.pem | 13 +
tests/certificate-authority/ec/server.conf | 40 ++
tests/certificate-authority/ec/server.csr.pem | 7 +
tests/certificate-authority/ec/server.key-pk8.pem | 5 +
tests/certificate-authority/ec/server.key.pem | 8 +
tests/docker-images/java-test-image/Dockerfile | 4 +-
.../integration/functions/PulsarStateTest.java | 46 ++-
.../impl/FileSystemManagedLedgerOffloader.java | 4 +
.../offload/filesystem/FileStoreTestBase.java | 26 +-
.../impl/FileSystemManagedLedgerOffloaderTest.java | 16 +
.../offload/jcloud/impl/MockManagedLedger.java | 4 +-
214 files changed, 5629 insertions(+), 1493 deletions(-)
delete mode 100644 .github/workflows/ci-stale-issue-pr.yaml
create mode 100644 pip/pip-300.md
create mode 100644 pip/pip-303.md
create mode 100644 pip/pip-312.md
create mode 100644 pip/pip-315.md
create mode 100644 pip/pip-318.md
copy {pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin =>
pulsar-broker/src/main/java/org/apache/pulsar/broker/service}/GetStatsOptions.java
(81%)
rename
pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/{MangedLedgerInterceptorImplTest2.java
=> MangedLedgerInterceptorImpl2Test.java} (96%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TopicGCTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/TopicSchemaTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/OrphanPersistentTopicTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerDisallowAutoCreateTopicTest.java
rename
pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/{PulsarFunctionTestUtils.java
=> TestPulsarFunctionUtils.java} (98%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/security/tls/MockedPulsarStandalone.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/security/tls/ec/TlsWithECCertificateFileTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/security/tls/ec/TlsWithECKeyStoreTest.java
rename
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/{ProxyKeyStoreTlsTestWithAuth.java
=> ProxyKeyStoreTlsWithAuthTest.java} (99%)
rename
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/{ProxyKeyStoreTlsTestWithoutAuth.java
=> ProxyKeyStoreTlsWithoutAuthTest.java} (99%)
rename
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/{ProxyTlsTestWithAuth.java
=> ProxyTlsWithAuthTest.java} (98%)
create mode 100644
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/MultiTopicConsumerHandler.java
create mode 100644
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketMultiTopicConsumerServlet.java
create mode 100644 tests/certificate-authority/ec/broker_client.cert.pem
create mode 100644 tests/certificate-authority/ec/broker_client.csr.pem
create mode 100644 tests/certificate-authority/ec/broker_client.key-pk8.pem
create mode 100644 tests/certificate-authority/ec/broker_client.key.pem
create mode 100644 tests/certificate-authority/ec/ca.cert.pem
create mode 100644 tests/certificate-authority/ec/ca.cert.srl
create mode 100644 tests/certificate-authority/ec/ca.key.pem
create mode 100644 tests/certificate-authority/ec/certificate_generation.txt
create mode 100644 tests/certificate-authority/ec/client.cert.pem
create mode 100644 tests/certificate-authority/ec/client.csr.pem
create mode 100644 tests/certificate-authority/ec/client.key-pk8.pem
create mode 100644 tests/certificate-authority/ec/client.key.pem
create mode 100644 tests/certificate-authority/ec/jks/broker_client.cert.pem
create mode 100644
tests/certificate-authority/ec/jks/broker_client.keystore.jks
create mode 100644
tests/certificate-authority/ec/jks/broker_client.signed.cert.pem
create mode 100644 tests/certificate-authority/ec/jks/ca.cert.pem
create mode 100644 tests/certificate-authority/ec/jks/ca.cert.srl
create mode 100644 tests/certificate-authority/ec/jks/ca.key.pem
create mode 100644 tests/certificate-authority/ec/jks/ca.truststore.jks
create mode 100644 tests/certificate-authority/ec/jks/client.cert.pem
create mode 100644 tests/certificate-authority/ec/jks/client.keystore.jks
create mode 100644 tests/certificate-authority/ec/jks/client.signed.cert.pem
create mode 100644 tests/certificate-authority/ec/jks/key_store_generation.txt
create mode 100644 tests/certificate-authority/ec/jks/server.cert.pem
create mode 100644 tests/certificate-authority/ec/jks/server.keystore.jks
create mode 100644 tests/certificate-authority/ec/jks/server.signed.cert.pem
create mode 100644 tests/certificate-authority/ec/server.cert.pem
create mode 100644 tests/certificate-authority/ec/server.conf
create mode 100644 tests/certificate-authority/ec/server.csr.pem
create mode 100644 tests/certificate-authority/ec/server.key-pk8.pem
create mode 100644 tests/certificate-authority/ec/server.key.pem
