You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ur...@apache.org on 2022/06/01 08:25:26 UTC
[pulsar] 01/01: Merge branch 'master' into fix/remove-website-build-workflow
This is an automated email from the ASF dual-hosted git repository.
urfree pushed a commit to branch fix/remove-website-build-workflow
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit ae2df8d7e1747f0009b9e090b57bfb01f14c6733
Merge: 043c0859be8 aa673498f88
Author: Li Li <ur...@apache.org>
AuthorDate: Wed Jun 1 16:25:12 2022 +0800
Merge branch 'master' into fix/remove-website-build-workflow
.../resources/authentication/tls/broker-cert.pem | 74 ++++++-------
.../test/resources/authentication/tls/cacert.pem | 110 ++++++++++----------
.../resources/authentication/tls/client-cert.pem | 74 ++++++-------
build/regenerate_certs_for_tests.sh | 25 ++---
conf/broker.conf | 14 ++-
conf/functions_worker.yml | 20 ++++
conf/proxy.conf | 4 +
conf/websocket.conf | 4 +
.../pulsar/broker/BookKeeperClientFactoryImpl.java | 16 ++-
.../org/apache/pulsar/broker/PulsarService.java | 33 ++++--
.../pulsar/broker/namespace/NamespaceService.java | 6 ++
.../pulsar/broker/service/BrokerService.java | 21 +++-
.../apache/pulsar/compaction/CompactorTool.java | 6 ++
...kerInternalClientConfigurationOverrideTest.java | 115 +++++++++++++++++++++
.../AuthenticationTlsHostnameVerificationTest.java | 34 ++----
.../PulsarClientConfigurationOverrideTest.java | 56 ++++++++++
.../websocket/proxy/ProxyConfigurationTest.java | 6 ++
.../pulsar/client/admin/PulsarAdminBuilder.java | 23 +++++
.../admin/internal/PulsarAdminBuilderImpl.java | 9 +-
.../admin/internal/http/AsyncHttpConnector.java | 9 +-
.../pulsar/client/internal/PropertiesUtils.java | 64 ++++++++++++
.../org/apache/pulsar/client/impl/ClientCnx.java | 49 ---------
.../org/apache/pulsar/client/impl/HttpClient.java | 1 +
.../client/impl/PulsarChannelInitializer.java | 7 ++
.../util/NettyClientSslContextRefresher.java | 3 +-
.../apache/pulsar/common/util/SecurityUtility.java | 10 ++
.../src/test/resources/test_worker_config.yml | 3 +
.../functions/worker/PulsarWorkerService.java | 12 ++-
.../pulsar/functions/worker/WorkerUtils.java | 45 +++++++-
.../pulsar/functions/worker/WorkerUtilsTest.java | 19 ++++
.../bookkeeper/BookKeeperPackagesStorage.java | 8 ++
.../BookKeeperPackagesStorageConfiguration.java | 4 +
.../core/PackagesStorageConfiguration.java | 6 ++
.../impl/DefaultPackagesStorageConfiguration.java | 5 +
.../pulsar/proxy/server/AdminProxyHandler.java | 7 +-
.../pulsar/proxy/server/DirectProxyHandler.java | 101 +++++++++++++-----
.../pulsar/proxy/server/ProxyConnection.java | 24 +++--
.../proxy/server/ServiceChannelInitializer.java | 66 +-----------
.../proxy/server/ProxyWithAuthorizationTest.java | 70 +++++++------
.../ProxyWithAuthorizationTest/broker-cacert.pem | 110 ++++++++++----------
.../tls/ProxyWithAuthorizationTest/broker-cert.pem | 74 ++++++-------
.../ProxyWithAuthorizationTest/client-cacert.pem | 110 ++++++++++----------
.../tls/ProxyWithAuthorizationTest/client-cert.pem | 74 ++++++-------
.../ProxyWithAuthorizationTest/proxy-cacert.pem | 110 ++++++++++----------
.../tls/ProxyWithAuthorizationTest/proxy-cert.pem | 74 ++++++-------
.../test/resources/authentication/tls/cacert.pem | 110 ++++++++++----------
.../resources/authentication/tls/client-cert.pem | 74 ++++++-------
.../resources/authentication/tls/server-cert.pem | 74 ++++++-------
.../apache/pulsar/websocket/WebSocketService.java | 7 +-
site2/docs/reference-configuration.md | 21 ++++
site2/website/api.sh | 31 ++++++
site2/website/start.sh | 1 +
.../tests/integration/io/PulsarIOTestBase.java | 48 +++++----
.../tests/integration/io/RabbitMQSinkTester.java | 5 +
.../tests/integration/io/RabbitMQSourceTester.java | 5 +
.../integration/io/sinks/CassandraSinkTester.java | 12 +++
.../io/sinks/ElasticSearchSinkTester.java | 7 ++
.../tests/integration/io/sinks/HdfsSinkTester.java | 4 +
.../io/sinks/JdbcPostgresSinkTester.java | 8 ++
.../integration/io/sinks/KafkaSinkTester.java | 56 +++++-----
.../integration/io/sinks/KinesisSinkTester.java | 8 ++
.../integration/io/sinks/OpenSearchSinkTester.java | 9 +-
.../tests/integration/io/sinks/SinkTester.java | 4 +-
.../integration/io/sources/KafkaSourceTester.java | 8 ++
.../tests/integration/io/sources/SourceTester.java | 2 +-
.../debezium/DebeziumMongoDbSourceTester.java | 11 +-
.../debezium/DebeziumMsSqlSourceTester.java | 11 +-
.../debezium/DebeziumMySqlSourceTester.java | 9 +-
.../debezium/DebeziumOracleDbSourceTester.java | 11 +-
.../debezium/DebeziumPostgreSqlSourceTester.java | 13 +--
.../debezium/PulsarIODebeziumSourceRunner.java | 18 +++-
71 files changed, 1422 insertions(+), 860 deletions(-)