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 <[email protected]> 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(-)
