| # |
| # Licensed to the Apache Software Foundation (ASF) under one |
| # or more contributor license agreements. See the NOTICE file |
| # distributed with this work for additional information |
| # regarding copyright ownership. The ASF licenses this file |
| # to you under the Apache License, Version 2.0 (the |
| # "License"); you may not use this file except in compliance |
| # with the License. You may obtain a copy of the License at |
| # |
| # http://www.apache.org/licenses/LICENSE-2.0 |
| # |
| # Unless required by applicable law or agreed to in writing, |
| # software distributed under the License is distributed on an |
| # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| # KIND, either express or implied. See the License for the |
| # specific language governing permissions and limitations |
| # under the License. |
| # |
| |
| # name of the connector to be displayed in the catalog |
| connector.name=pulsar |
| # the url of Pulsar broker service |
| pulsar.broker-service-url=http://localhost:8080 |
| # URI of Zookeeper cluster |
| pulsar.zookeeper-uri=127.0.0.1:2181 |
| # minimum number of entries to read at a single time |
| pulsar.max-entry-read-batch-size=100 |
| # default number of splits to use per query |
| pulsar.target-num-splits=2 |
| # max message queue size |
| pulsar.max-split-message-queue-size=10000 |
| # max entry queue size |
| pulsar.max-split-entry-queue-size=1000 |
| # half of this value is used as max entry queue size bytes and the left is used as max message queue size bytes, |
| # the queue size bytes shouldn't exceed this value, but it's not strict, the default value -1 indicate no limit. |
| pulsar.max-split-queue-cache-size=-1 |
| # Rewrite namespace delimiter |
| # Warn: avoid using symbols allowed by Namespace (a-zA-Z_0-9 -=:%) |
| # to prevent erroneous rewriting |
| pulsar.namespace-delimiter-rewrite-enable=false |
| pulsar.rewrite-namespace-delimiter=/ |
| |
| |
| ####### TIERED STORAGE OFFLOADER CONFIGS ####### |
| |
| ## Driver to use to offload old data to long term storage |
| #pulsar.managed-ledger-offload-driver = aws-s3 |
| |
| ## The directory to locate offloaders |
| #pulsar.offloaders-directory = /pulsar/offloaders |
| |
| ## Maximum number of thread pool threads for ledger offloading |
| #pulsar.managed-ledger-offload-max-threads = 2 |
| |
| ## Properties and configurations related to specific offloader implementation |
| #pulsar.offloader-properties = \ |
| # {"s3ManagedLedgerOffloadBucket": "offload-bucket", \ |
| # "s3ManagedLedgerOffloadRegion": "us-west-2", \ |
| # "s3ManagedLedgerOffloadServiceEndpoint": "http://s3.amazonaws.com"} |
| |
| |
| ####### AUTHENTICATION CONFIGS ####### |
| |
| ## the authentication plugin to be used to authenticate to Pulsar cluster |
| #pulsar.auth-plugin = |
| |
| ## the authentication parameter to be used to authenticate to Pulsar cluster |
| #pulsar.auth-params = |
| |
| ## Accept untrusted TLS certificate |
| #pulsar.tls-allow-insecure-connection = |
| |
| ## Whether to enable hostname verification on TLS connections |
| #pulsar.tls-hostname-verification-enable = |
| |
| ## Path for the trusted TLS certificate file |
| #pulsar.tls-trust-cert-file-path = |
| |
| ####### BOOKKEEPER CONFIGS ####### |
| |
| # Entries read count throttling-limit per seconds, 0 is represents disable the throttle, default is 0. |
| pulsar.bookkeeper-throttle-value = 0 |
| |
| # The number of threads used by Netty to handle TCP connections, |
| # default is 2 * Runtime.getRuntime().availableProcessors(). |
| # pulsar.bookkeeper-num-io-threads = |
| |
| # The number of worker threads used by bookkeeper client to submit operations, |
| # default is Runtime.getRuntime().availableProcessors(). |
| # pulsar.bookkeeper-num-worker-threads = |
| |
| # Whether the bookkeeper client use v2 protocol or v3 protocol. |
| # Default is the v2 protocol which the LAC is piggy back lac. Otherwise the client |
| # will use v3 protocol and use explicit lac. |
| pulsar.bookkeeper-use-v2-protocol=true |
| pulsar.bookkeeper-explicit-interval=0 |
| |
| ####### MANAGED LEDGER CONFIGS ####### |
| |
| # Amount of memory to use for caching data payload in managed ledger. This memory |
| # is allocated from JVM direct memory and it's shared across all the managed ledgers |
| # running in same sql worker. 0 is represents disable the cache, default is 0. |
| pulsar.managed-ledger-cache-size-MB = 0 |
| |
| # Number of threads to be used for managed ledger tasks dispatching, |
| # default is Runtime.getRuntime().availableProcessors(). |
| # pulsar.managed-ledger-num-worker-threads = |
| |
| # Number of threads to be used for managed ledger scheduled tasks, |
| # default is Runtime.getRuntime().availableProcessors(). |
| # pulsar.managed-ledger-num-scheduler-threads = |
| |
| ####### PROMETHEUS CONFIGS ####### |
| |
| # pulsar.stats-provider=org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider |
| # pulsar.stats-provider-configs={"httpServerEnabled":"false", "prometheusStatsHttpPort":"9092", "prometheusStatsHttpEnable":"true"} |