前面我们介绍了pulsar的基本概念，这篇呢，我们主要就搭建一个pulsar单机版，然后运行一下，看下pulsar的样子。这里由于演示服务器有限，因此这里直接是部署单机，有条件的可以部署集群。
1）首先下载pulsar的包，这里我们下载的是2.8.0的包
cd /mnt wget https://archive.apache.org/dist/pulsar/pulsar-2.8.0/apache-pulsar-2.8.0-bin.tar.gz tar -zxvf apache-pulsar-2.8.0-bin.tar.gz mv apache-pulsar-2.8.0 .. cd apache-pulsar-2.8.0
2）上面我们已经把pulsar的包下载下来了，所以这里我们来看下apache-pulsar-2.8.0的完整结构
apache-pulsar-2.8.0 ├── bin │ ├── bookkeeper │ ├── function-localrunner │ ├── proto │ │ ├── __init__.py │ │ └── MLDataFormats_pb2.py │ ├── pulsar │ ├── pulsar-admin │ ├── pulsar-admin-common.sh │ ├── pulsar-bookie.pid │ ├── pulsar-broker.pid │ ├── pulsar-client │ ├── pulsar-daemon │ ├── pulsar-managed-ledger-admin │ └── pulsar-perf ├── conf │ ├── bkenv.sh │ ├── bookkeeper.conf │ ├── broker.conf │ ├── client.conf │ ├── discovery.conf │ ├── filesystem_offload_core_site.xml │ ├── functions_log4j2.xml │ ├── functions-logging │ │ ├── console_logging_config.ini │ │ └── logging_config.ini │ ├── functions_worker.yml │ ├── global_zookeeper.conf │ ├── log4j2-scripts │ │ └── filter.js │ ├── log4j2.yaml │ ├── presto │ │ ├── catalog │ │ │ └── pulsar.properties │ │ ├── config.properties │ │ ├── jvm.config │ │ └── log.properties │ ├── proxy.conf │ ├── pulsar_env.sh │ ├── pulsar_tools_env.sh │ ├── schema_example.conf │ ├── standalone.conf │ ├── websocket.conf │ └── zookeeper.conf ├── data │ ├── bookkeeper │ │ ├── journal │ │ │ └── current │ │ │ ├── 181ff8e963b.txn │ │ │ └── VERSION │ │ └── ledgers │ │ └── current │ │ ├── 0.log │ │ ├── 1.log │ │ ├── lastId │ │ ├── lastMark │ │ ├── ledgers │ │ │ ├── 000006.log │ │ │ ├── 000007.sst │ │ │ ├── CURRENT │ │ │ ├── IDENTITY │ │ │ ├── LOCK │ │ │ ├── LOG │ │ │ ├── MANIFEST-000008 │ │ │ └── OPTIONS-000005 │ │ ├── locations │ │ │ ├── 000006.log │ │ │ ├── 000007.sst │ │ │ ├── CURRENT │ │ │ ├── IDENTITY │ │ │ ├── LOCK │ │ │ ├── LOG │ │ │ ├── MANIFEST-000008 │ │ │ └── OPTIONS-000005 │ │ └── VERSION │ └── standalone │ ├── bookkeeper │ │ └── ranges │ │ └── data │ │ └── ranges │ │ ├── 000000000000000000 │ │ │ ├── 000000000000000000 │ │ │ │ └── 000000000000000000 │ │ │ │ ├── checkpoints │ │ │ │ │ └── 7366ebb8-d896-4be7-a9ff-6624e538193c │ │ │ │ │ ├── 000003.log │ │ │ │ │ ├── 000009.sst │ │ │ │ │ ├── 000010.sst │ │ │ │ │ ├── CURRENT │ │ │ │ │ ├── IDENTITY │ │ │ │ │ ├── LOCK │ │ │ │ │ ├── LOG │ │ │ │ │ ├── MANIFEST-000004 │ │ │ │ │ ├── OPTIONS-000006 │ │ │ │ │ └── OPTIONS-000008 │ │ │ │ └── current -> /mnt/apache-pulsar-2.8.0/data/standalone/bookkeeper/ranges/data/ranges/000000000000000000/000000000000000000/000000000000000000/checkpoints/7366ebb8-d896-4be7-a9ff-6624e538193c │ │ │ └── 000000000000000001 │ │ │ └── 000000000000000000 │ │ │ ├── checkpoints │ │ │ │ └── 5687d1f4-482a-4fcb-8ca5-cbfc1eae2ea3 │ │ │ │ ├── 000003.log │ │ │ │ ├── CURRENT │ │ │ │ ├── IDENTITY │ │ │ │ ├── LOCK │ │ │ │ ├── LOG │ │ │ │ ├── MANIFEST-000004 │ │ │ │ ├── OPTIONS-000006 │ │ │ │ └── OPTIONS-000008 │ │ │ └── current -> /mnt/apache-pulsar-2.8.0/data/standalone/bookkeeper/ranges/data/ranges/000000000000000000/000000000000000001/000000000000000000/checkpoints/5687d1f4-482a-4fcb-8ca5-cbfc1eae2ea3 │ │ └── 000000000000000001 │ │ └── 000000000000000001 │ │ └── 000000000000000000 │ │ ├── checkpoints │ │ │ └── a22f9840-9d20-4caf-9554-152015670d2a │ │ │ ├── 000003.log │ │ │ ├── CURRENT │ │ │ ├── IDENTITY │ │ │ ├── LOCK │ │ │ ├── LOG │ │ │ ├── MANIFEST-000004 │ │ │ ├── OPTIONS-000006 │ │ │ └── OPTIONS-000008 │ │ └── current -> /mnt/apache-pulsar-2.8.0/data/standalone/bookkeeper/ranges/data/ranges/000000000000000001/000000000000000001/000000000000000000/checkpoints/a22f9840-9d20-4caf-9554-152015670d2a │ ├── bookkeeper0 │ │ └── current │ │ ├── 0.log │ │ ├── 1820083a172.txn │ │ ├── 1.log │ │ ├── lastId │ │ ├── lastMark │ │ ├── ledgers │ │ │ ├── 000003.log │ │ │ ├── CURRENT │ │ │ ├── IDENTITY │ │ │ ├── LOCK │ │ │ ├── LOG │ │ │ ├── MANIFEST-000001 │ │ │ └── OPTIONS-000005 │ │ ├── locations │ │ │ ├── 000003.log │ │ │ ├── CURRENT │ │ │ ├── IDENTITY │ │ │ ├── LOCK │ │ │ ├── LOG │ │ │ ├── MANIFEST-000001 │ │ │ └── OPTIONS-000005 │ │ └── VERSION │ └── zookeeper │ └── version-2 │ ├── log.1 │ └── snapshot.0 ├── examples │ ├── api-examples.jar │ ├── example-function-config.yaml │ ├── example-window-function-config.yaml │ └── python-examples │ ├── config_based_append_function.py │ ├── custom_object_function.py │ ├── exclamation_function.py │ ├── logging_function.py │ ├── native_exclamation_function.py │ ├── publish_function.py │ ├── thumbnailer.py │ ├── typed_message_builder_publish.py │ ├── user_exception.py │ ├── void_function.py │ └── wordcount_function.py ├── instances │ ├── deps │ ├── java-instance.jar │ └── python-instance │ ├── contextimpl.py │ ├── Function_pb2.py │ ├── function_stats.py │ ├── __init__.py │ ├── InstanceCommunication_pb2_grpc.py │ ├── InstanceCommunication_pb2.py │ ├── log.py │ ├── prometheus_client_fix.py │ ├── pulsar │ │ ├── exceptions.py │ │ ├── functions │ │ │ ├── context.py │ │ │ ├── function.py │ │ │ ├── __init__.py │ │ │ └── serde.py │ │ ├── __init__.py │ │ └── schema │ │ ├── definition.py │ │ ├── __init__.py │ │ └── schema.py │ ├── python_instance_main.py │ ├── python_instance.py │ ├── secretsprovider.py │ ├── server.py │ ├── state_context.py │ ├── tests │ │ ├── test_python_instance.py │ │ └── test_secretsprovider.py │ └── util.py ├── lib │ ├── com.beust-jcommander-1.78.jar │ ├── com.carrotsearch-hppc-0.7.3.jar │ ├── com.fasterxml.jackson.core-jackson-annotations-2.12.3.jar │ ├── com.fasterxml.jackson.core-jackson-core-2.12.3.jar │ ├── com.fasterxml.jackson.core-jackson-databind-2.12.3.jar │ ├── com.fasterxml.jackson.dataformat-jackson-dataformat-yaml-2.12.3.jar │ ├── com.fasterxml.jackson.jaxrs-jackson-jaxrs-base-2.12.3.jar │ ├── com.fasterxml.jackson.jaxrs-jackson-jaxrs-json-provider-2.12.3.jar │ ├── com.fasterxml.jackson.module-jackson-module-jaxb-annotations-2.12.3.jar │ ├── com.fasterxml.jackson.module-jackson-module-jsonSchema-2.12.3.jar │ ├── com.github.ben-manes.caffeine-caffeine-2.6.2.jar │ ├── com.github.zafarkhaja-java-semver-0.9.0.jar │ ├── com.google.api.grpc-proto-google-common-protos-1.17.0.jar │ ├── com.google.auth-google-auth-library-credentials-0.20.0.jar │ ├── com.google.auth-google-auth-library-oauth2-http-0.20.0.jar │ ├── com.google.auto.value-auto-value-annotations-1.7.jar │ ├── com.google.code.findbugs-jsr305-3.0.2.jar │ ├── com.google.code.gson-gson-2.8.6.jar │ ├── com.google.errorprone-error_prone_annotations-2.5.1.jar │ ├── com.google.guava-failureaccess-1.0.1.jar │ ├── com.google.guava-guava-30.1-jre.jar │ ├── com.google.guava-listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar │ ├── com.google.http-client-google-http-client-1.34.0.jar │ ├── com.google.http-client-google-http-client-jackson2-1.34.0.jar │ ├── com.google.j2objc-j2objc-annotations-1.3.jar │ ├── com.google.protobuf-protobuf-java-3.11.4.jar │ ├── com.google.protobuf-protobuf-java-util-3.11.4.jar │ ├── com.google.re2j-re2j-1.2.jar │ ├── commons-cli-commons-cli-1.2.jar │ ├── commons-codec-commons-codec-1.10.jar │ ├── commons-collections-commons-collections-3.2.2.jar │ ├── commons-configuration-commons-configuration-1.10.jar │ ├── commons-io-commons-io-2.8.0.jar │ ├── commons-lang-commons-lang-2.6.jar │ ├── commons-logging-commons-logging-1.1.1.jar │ ├── com.squareup.okhttp3-logging-interceptor-3.14.9.jar │ ├── com.squareup.okhttp3-okhttp-3.14.9.jar │ ├── com.squareup.okhttp-okhttp-2.7.4.jar │ ├── com.squareup.okio-okio-1.13.0.jar │ ├── com.sun.activation-javax.activation-1.2.0.jar │ ├── com.typesafe.netty-netty-reactive-streams-2.0.4.jar │ ├── com.yahoo.datasketches-memory-0.8.3.jar │ ├── com.yahoo.datasketches-sketches-core-0.8.3.jar │ ├── io.airlift-aircompressor-0.16.jar │ ├── io.dropwizard.metrics-metrics-core-3.2.5.jar │ ├── io.dropwizard.metrics-metrics-graphite-3.2.5.jar │ ├── io.dropwizard.metrics-metrics-jvm-3.2.5.jar │ ├── io.grpc-grpc-all-1.33.0.jar │ ├── io.grpc-grpc-alts-1.33.0.jar │ ├── io.grpc-grpc-api-1.33.0.jar │ ├── io.grpc-grpc-auth-1.33.0.jar │ ├── io.grpc-grpc-context-1.33.0.jar │ ├── io.grpc-grpc-core-1.33.0.jar │ ├── io.grpc-grpc-grpclb-1.33.0.jar │ ├── io.grpc-grpc-netty-1.33.0.jar │ ├── io.grpc-grpc-netty-shaded-1.33.0.jar │ ├── io.grpc-grpc-okhttp-1.33.0.jar │ ├── io.grpc-grpc-protobuf-1.33.0.jar │ ├── io.grpc-grpc-protobuf-lite-1.33.0.jar │ ├── io.grpc-grpc-services-1.33.0.jar │ ├── io.grpc-grpc-stub-1.33.0.jar │ ├── io.grpc-grpc-xds-1.33.0.jar │ ├── io.gsonfire-gson-fire-1.8.5.jar │ ├── io.jsonwebtoken-jjwt-api-0.11.1.jar │ ├── io.jsonwebtoken-jjwt-impl-0.11.1.jar │ ├── io.jsonwebtoken-jjwt-jackson-0.11.1.jar │ ├── io.kubernetes-client-java-12.0.0.jar │ ├── io.kubernetes-client-java-api-12.0.0.jar │ ├── io.kubernetes-client-java-proto-12.0.0.jar │ ├── io.netty-netty-buffer-4.1.63.Final.jar │ ├── io.netty-netty-codec-4.1.63.Final.jar │ ├── io.netty-netty-codec-dns-4.1.63.Final.jar │ ├── io.netty-netty-codec-haproxy-4.1.63.Final.jar │ ├── io.netty-netty-codec-http2-4.1.63.Final.jar │ ├── io.netty-netty-codec-http-4.1.63.Final.jar │ ├── io.netty-netty-codec-socks-4.1.63.Final.jar │ ├── io.netty-netty-common-4.1.63.Final.jar │ ├── io.netty-netty-handler-4.1.63.Final.jar │ ├── io.netty-netty-handler-proxy-4.1.63.Final.jar │ ├── io.netty-netty-resolver-4.1.63.Final.jar │ ├── io.netty-netty-resolver-dns-4.1.63.Final.jar │ ├── io.netty-netty-tcnative-boringssl-static-2.0.38.Final.jar │ ├── io.netty-netty-transport-4.1.63.Final.jar │ ├── io.netty-netty-transport-native-epoll-4.1.63.Final.jar │ ├── io.netty-netty-transport-native-epoll-4.1.63.Final-linux-x86_64.jar │ ├── io.netty-netty-transport-native-unix-common-4.1.63.Final.jar │ ├── io.netty-netty-transport-native-unix-common-4.1.63.Final-linux-x86_64.jar │ ├── io.opencensus-opencensus-api-0.18.0.jar │ ├── io.opencensus-opencensus-contrib-http-util-0.24.0.jar │ ├── io.opencensus-opencensus-proto-0.2.0.jar │ ├── io.perfmark-perfmark-api-0.19.0.jar │ ├── io.prometheus.jmx-collector-0.14.0.jar │ ├── io.prometheus-simpleclient-0.5.0.jar │ ├── io.prometheus-simpleclient_caffeine-0.5.0.jar │ ├── io.prometheus-simpleclient_common-0.5.0.jar │ ├── io.prometheus-simpleclient_hotspot-0.5.0.jar │ ├── io.prometheus-simpleclient_httpserver-0.5.0.jar │ ├── io.prometheus-simpleclient_jetty-0.5.0.jar │ ├── io.prometheus-simpleclient_log4j2-0.5.0.jar │ ├── io.prometheus-simpleclient_servlet-0.5.0.jar │ ├── io.swagger-swagger-annotations-1.6.2.jar │ ├── io.swagger-swagger-core-1.6.2.jar │ ├── io.swagger-swagger-models-1.6.2.jar │ ├── io.vertx-vertx-auth-common-3.5.4.jar │ ├── io.vertx-vertx-bridge-common-3.5.4.jar │ ├── io.vertx-vertx-core-3.5.4.jar │ ├── io.vertx-vertx-web-3.5.4.jar │ ├── jakarta.activation-jakarta.activation-api-1.2.2.jar │ ├── jakarta.annotation-jakarta.annotation-api-1.3.5.jar │ ├── jakarta.validation-jakarta.validation-api-2.0.2.jar │ ├── jakarta.ws.rs-jakarta.ws.rs-api-2.1.6.jar │ ├── jakarta.xml.bind-jakarta.xml.bind-api-2.3.3.jar │ ├── javax.annotation-javax.annotation-api-1.3.2.jar │ ├── javax.servlet-javax.servlet-api-3.1.0.jar │ ├── javax.validation-validation-api-1.1.0.Final.jar │ ├── javax.websocket-javax.websocket-client-api-1.0.jar │ ├── javax.ws.rs-javax.ws.rs-api-2.1.jar │ ├── javax.xml.bind-jaxb-api-2.3.1.jar │ ├── net.java.dev.jna-jna-4.2.0.jar │ ├── net.jcip-jcip-annotations-1.0.jar │ ├── net.jodah-typetools-0.5.0.jar │ ├── org.apache.avro-avro-1.10.2.jar │ ├── org.apache.avro-avro-protobuf-1.10.2.jar │ ├── org.apache.bookkeeper-bookkeeper-common-4.14.1.jar │ ├── org.apache.bookkeeper-bookkeeper-common-allocator-4.14.1.jar │ ├── org.apache.bookkeeper-bookkeeper-proto-4.14.1.jar │ ├── org.apache.bookkeeper-bookkeeper-server-4.14.1.jar │ ├── org.apache.bookkeeper-bookkeeper-tools-framework-4.14.1.jar │ ├── org.apache.bookkeeper-circe-checksum-4.14.1.jar │ ├── org.apache.bookkeeper-cpu-affinity-4.14.1.jar │ ├── org.apache.bookkeeper.http-http-server-4.14.1.jar │ ├── org.apache.bookkeeper.http-vertx-http-server-4.14.1.jar │ ├── org.apache.bookkeeper-statelib-4.14.1.jar │ ├── org.apache.bookkeeper.stats-bookkeeper-stats-api-4.14.1.jar │ ├── org.apache.bookkeeper.stats-codahale-metrics-provider-4.14.1.jar │ ├── org.apache.bookkeeper.stats-prometheus-metrics-provider-4.14.1.jar │ ├── org.apache.bookkeeper-stream-storage-api-4.14.1.jar │ ├── org.apache.bookkeeper-stream-storage-common-4.14.1.jar │ ├── org.apache.bookkeeper-stream-storage-java-client-4.14.1.jar │ ├── org.apache.bookkeeper-stream-storage-java-client-base-4.14.1.jar │ ├── org.apache.bookkeeper-stream-storage-proto-4.14.1.jar │ ├── org.apache.bookkeeper-stream-storage-server-4.14.1.jar │ ├── org.apache.bookkeeper-stream-storage-service-api-4.14.1.jar │ ├── org.apache.bookkeeper-stream-storage-service-impl-4.14.1.jar │ ├── org.apache.commons-commons-collections4-4.1.jar │ ├── org.apache.commons-commons-compress-1.19.jar │ ├── org.apache.commons-commons-lang3-3.11.jar │ ├── org.apache.curator-curator-client-5.1.0.jar │ ├── org.apache.curator-curator-framework-5.1.0.jar │ ├── org.apache.curator-curator-recipes-5.1.0.jar │ ├── org.apache.distributedlog-distributedlog-common-4.14.1.jar │ ├── org.apache.distributedlog-distributedlog-core-4.14.1.jar │ ├── org.apache.distributedlog-distributedlog-core-4.14.1-tests.jar │ ├── org.apache.distributedlog-distributedlog-protocol-4.14.1.jar │ ├── org.apache.httpcomponents-httpclient-4.5.13.jar │ ├── org.apache.httpcomponents-httpcore-4.4.13.jar │ ├── org.apache.logging.log4j-log4j-1.2-api-2.14.0.jar │ ├── org.apache.logging.log4j-log4j-api-2.14.0.jar │ ├── org.apache.logging.log4j-log4j-core-2.14.0.jar │ ├── org.apache.logging.log4j-log4j-slf4j-impl-2.14.0.jar │ ├── org.apache.logging.log4j-log4j-web-2.14.0.jar │ ├── org.apache.pulsar-bouncy-castle-bc-2.8.0-pkg.jar │ ├── org.apache.pulsar-managed-ledger-2.8.0.jar │ ├── org.apache.pulsar-pulsar-broker-2.8.0.jar │ ├── org.apache.pulsar-pulsar-broker-auth-sasl-2.8.0.jar │ ├── org.apache.pulsar-pulsar-broker-common-2.8.0.jar │ ├── org.apache.pulsar-pulsar-client-admin-api-2.8.0.jar │ ├── org.apache.pulsar-pulsar-client-admin-original-2.8.0.jar │ ├── org.apache.pulsar-pulsar-client-api-2.8.0.jar │ ├── org.apache.pulsar-pulsar-client-auth-sasl-2.8.0.jar │ ├── org.apache.pulsar-pulsar-client-messagecrypto-bc-2.8.0.jar │ ├── org.apache.pulsar-pulsar-client-original-2.8.0.jar │ ├── org.apache.pulsar-pulsar-client-tools-2.8.0.jar │ ├── org.apache.pulsar-pulsar-common-2.8.0.jar │ ├── org.apache.pulsar-pulsar-config-validation-2.8.0.jar │ ├── org.apache.pulsar-pulsar-discovery-service-2.8.0.jar │ ├── org.apache.pulsar-pulsar-functions-api-2.8.0.jar │ ├── org.apache.pulsar-pulsar-functions-instance-2.8.0.jar │ ├── org.apache.pulsar-pulsar-functions-local-runner-original-2.8.0.jar │ ├── org.apache.pulsar-pulsar-functions-proto-2.8.0.jar │ ├── org.apache.pulsar-pulsar-functions-runtime-2.8.0.jar │ ├── org.apache.pulsar-pulsar-functions-secrets-2.8.0.jar │ ├── org.apache.pulsar-pulsar-functions-utils-2.8.0.jar │ ├── org.apache.pulsar-pulsar-functions-worker-2.8.0.jar │ ├── org.apache.pulsar-pulsar-io-core-2.8.0.jar │ ├── org.apache.pulsar-pulsar-metadata-2.8.0.jar │ ├── org.apache.pulsar-pulsar-package-bookkeeper-storage-2.8.0.jar │ ├── org.apache.pulsar-pulsar-package-core-2.8.0.jar │ ├── org.apache.pulsar-pulsar-proxy-2.8.0.jar │ ├── org.apache.pulsar-pulsar-testclient-2.8.0.jar │ ├── org.apache.pulsar-pulsar-transaction-common-2.8.0.jar │ ├── org.apache.pulsar-pulsar-transaction-coordinator-2.8.0.jar │ ├── org.apache.pulsar-pulsar-websocket-2.8.0.jar │ ├── org.apache.pulsar-pulsar-zookeeper-utils-2.8.0.jar │ ├── org.apache.pulsar-testmocks-2.8.0.jar │ ├── org.apache.thrift-libthrift-0.12.0.jar │ ├── org.apache.yetus-audience-annotations-0.5.0.jar │ ├── org.apache.zookeeper-zookeeper-3.6.3.jar │ ├── org.apache.zookeeper-zookeeper-jute-3.6.3.jar │ ├── org.apache.zookeeper-zookeeper-prometheus-metrics-3.6.3.jar │ ├── org.asynchttpclient-async-http-client-2.12.1.jar │ ├── org.asynchttpclient-async-http-client-netty-utils-2.12.1.jar │ ├── org.bitbucket.b_c-jose4j-0.7.6.jar │ ├── org.bouncycastle-bcpkix-jdk15on-1.68.jar │ ├── org.bouncycastle-bcprov-ext-jdk15on-1.68.jar │ ├── org.bouncycastle-bcprov-jdk15on-1.68.jar │ ├── org.checkerframework-checker-qual-3.5.0.jar │ ├── org.conscrypt-conscrypt-openjdk-uber-2.5.2.jar │ ├── org.eclipse.jetty-jetty-alpn-conscrypt-server-9.4.42.v20210604.jar │ ├── org.eclipse.jetty-jetty-alpn-server-9.4.42.v20210604.jar │ ├── org.eclipse.jetty-jetty-client-9.4.42.v20210604.jar │ ├── org.eclipse.jetty-jetty-continuation-9.4.42.v20210604.jar │ ├── org.eclipse.jetty-jetty-http-9.4.42.v20210604.jar │ ├── org.eclipse.jetty-jetty-io-9.4.42.v20210604.jar │ ├── org.eclipse.jetty-jetty-proxy-9.4.42.v20210604.jar │ ├── org.eclipse.jetty-jetty-security-9.4.42.v20210604.jar │ ├── org.eclipse.jetty-jetty-server-9.4.42.v20210604.jar │ ├── org.eclipse.jetty-jetty-servlet-9.4.42.v20210604.jar │ ├── org.eclipse.jetty-jetty-servlets-9.4.42.v20210604.jar │ ├── org.eclipse.jetty-jetty-util-9.4.42.v20210604.jar │ ├── org.eclipse.jetty-jetty-util-ajax-9.4.42.v20210604.jar │ ├── org.eclipse.jetty.websocket-javax-websocket-client-impl-9.4.42.v20210604.jar │ ├── org.eclipse.jetty.websocket-websocket-api-9.4.42.v20210604.jar │ ├── org.eclipse.jetty.websocket-websocket-client-9.4.42.v20210604.jar │ ├── org.eclipse.jetty.websocket-websocket-common-9.4.42.v20210604.jar │ ├── org.eclipse.jetty.websocket-websocket-server-9.4.42.v20210604.jar │ ├── org.eclipse.jetty.websocket-websocket-servlet-9.4.42.v20210604.jar │ ├── org.glassfish.hk2.external-aopalliance-repackaged-2.6.1.jar │ ├── org.glassfish.hk2.external-jakarta.inject-2.6.1.jar │ ├── org.glassfish.hk2-hk2-api-2.6.1.jar │ ├── org.glassfish.hk2-hk2-locator-2.6.1.jar │ ├── org.glassfish.hk2-hk2-utils-2.6.1.jar │ ├── org.glassfish.hk2-osgi-resource-locator-1.0.3.jar │ ├── org.glassfish.jersey.containers-jersey-container-servlet-2.34.jar │ ├── org.glassfish.jersey.containers-jersey-container-servlet-core-2.34.jar │ ├── org.glassfish.jersey.core-jersey-client-2.34.jar │ ├── org.glassfish.jersey.core-jersey-common-2.34.jar │ ├── org.glassfish.jersey.core-jersey-server-2.34.jar │ ├── org.glassfish.jersey.ext-jersey-entity-filtering-2.34.jar │ ├── org.glassfish.jersey.inject-jersey-hk2-2.34.jar │ ├── org.glassfish.jersey.media-jersey-media-json-jackson-2.34.jar │ ├── org.glassfish.jersey.media-jersey-media-multipart-2.34.jar │ ├── org.hdrhistogram-HdrHistogram-2.1.9.jar │ ├── org.inferred-freebuilder-1.14.9.jar │ ├── org.javassist-javassist-3.25.0-GA.jar │ ├── org.jctools-jctools-core-2.1.2.jar │ ├── org.jvnet.mimepull-mimepull-1.9.13.jar │ ├── org.reactivestreams-reactive-streams-1.0.3.jar │ ├── org.rocksdb-rocksdbjni-6.10.2.jar │ ├── org.slf4j-jcl-over-slf4j-1.7.25.jar │ ├── org.slf4j-jul-to-slf4j-1.7.25.jar │ ├── org.slf4j-slf4j-api-1.7.25.jar │ ├── org.xerial.snappy-snappy-java-1.1.7.jar │ ├── org.yaml-snakeyaml-1.27.jar │ └── presto │ ├── bin │ │ ├── launcher │ │ ├── launcher.properties │ │ ├── launcher.py │ │ └── procname │ │ ├── Linux-ppc64le │ │ │ └── libprocname.so │ │ └── Linux-x86_64 │ │ └── libprocname.so │ ├── lib │ │ ├── aether-api-1.13.1.jar │ │ ├── aether-connector-asynchttpclient-1.13.1.jar │ │ ├── aether-connector-file-1.13.1.jar │ │ ├── aether-impl-1.13.1.jar │ │ ├── aether-spi-1.13.1.jar │ │ ├── aether-util-1.13.1.jar │ │ ├── aircompressor-0.16.jar │ │ ├── airline-0.8.jar │ │ ├── antlr4-runtime-4.7.1.jar │ │ ├── aopalliance-1.0.jar │ │ ├── aopalliance-repackaged-2.6.1.jar │ │ ├── asm-6.2.1.jar │ │ ├── asm-analysis-6.2.1.jar │ │ ├── asm-tree-6.2.1.jar │ │ ├── asm-util-6.2.1.jar │ │ ├── async-http-client-1.6.5.jar │ │ ├── bootstrap-0.195.jar │ │ ├── bval-jsr-2.0.0.jar │ │ ├── bytecode-1.2.jar │ │ ├── cglib-nodep-3.3.0.jar │ │ ├── checker-qual-3.5.0.jar │ │ ├── commons-math3-3.6.1.jar │ │ ├── concurrent-0.195.jar │ │ ├── configuration-0.195.jar │ │ ├── discovery-0.195.jar │ │ ├── discovery-server-1.29.jar │ │ ├── error_prone_annotations-2.5.1.jar │ │ ├── esri-geometry-api-2.2.2.jar │ │ ├── event-0.195.jar │ │ ├── failsafe-2.0.1.jar │ │ ├── failureaccess-1.0.1.jar │ │ ├── fastutil-8.3.0.jar │ │ ├── guava-30.1-jre.jar │ │ ├── guice-4.2.3.jar │ │ ├── guice-multibindings-4.2.0.jar │ │ ├── HdrHistogram-2.1.9.jar │ │ ├── hk2-api-2.6.1.jar │ │ ├── hk2-locator-2.6.1.jar │ │ ├── hk2-utils-2.6.1.jar │ │ ├── http2-client-9.4.42.v20210604.jar │ │ ├── http2-common-9.4.42.v20210604.jar │ │ ├── http2-hpack-9.4.42.v20210604.jar │ │ ├── http2-http-client-transport-9.4.42.v20210604.jar │ │ ├── http2-server-9.4.42.v20210604.jar │ │ ├── http-client-0.195.jar │ │ ├── http-server-0.195.jar │ │ ├── j2objc-annotations-1.3.jar │ │ ├── jackson-annotations-2.12.3.jar │ │ ├── jackson-core-2.12.3.jar │ │ ├── jackson-databind-2.12.3.jar │ │ ├── jackson-dataformat-smile-2.12.3.jar │ │ ├── jackson-dataformat-yaml-2.12.3.jar │ │ ├── jackson-datatype-guava-2.12.3.jar │ │ ├── jackson-datatype-jdk8-2.12.3.jar │ │ ├── jackson-datatype-joda-2.12.3.jar │ │ ├── jackson-datatype-jsr310-2.12.3.jar │ │ ├── jackson-module-parameter-names-2.12.3.jar │ │ ├── jakarta.annotation-api-1.3.5.jar │ │ ├── jakarta.inject-2.6.1.jar │ │ ├── jakarta.validation-api-2.0.2.jar │ │ ├── jakarta.ws.rs-api-2.1.6.jar │ │ ├── javassist-3.25.0-GA.jar │ │ ├── javax.activation-api-1.2.0.jar │ │ ├── javax.inject-1.jar │ │ ├── javax.servlet-api-4.0.1.jar │ │ ├── javax.ws.rs-api-2.1.jar │ │ ├── jaxb-api-2.3.1.jar │ │ ├── jaxrs-0.195.jar │ │ ├── jcl-over-slf4j-1.7.25.jar │ │ ├── jersey-client-2.34.jar │ │ ├── jersey-common-2.34.jar │ │ ├── jersey-container-servlet-2.34.jar │ │ ├── jersey-container-servlet-core-2.34.jar │ │ ├── jersey-hk2-2.34.jar │ │ ├── jersey-server-2.34.jar │ │ ├── jetty-alpn-client-9.4.42.v20210604.jar │ │ ├── jetty-alpn-java-client-9.4.42.v20210604.jar │ │ ├── jetty-client-9.4.42.v20210604.jar │ │ ├── jetty-http-9.4.42.v20210604.jar │ │ ├── jetty-io-9.4.42.v20210604.jar │ │ ├── jetty-jmx-9.4.42.v20210604.jar │ │ ├── jetty-security-9.4.42.v20210604.jar │ │ ├── jetty-server-9.4.42.v20210604.jar │ │ ├── jetty-servlet-9.4.42.v20210604.jar │ │ ├── jetty-util-9.4.42.v20210604.jar │ │ ├── jetty-util-ajax-9.4.42.v20210604.jar │ │ ├── jgrapht-core-0.9.0.jar │ │ ├── jjwt-0.9.0.jar │ │ ├── jline-reader-3.12.1.jar │ │ ├── jline-terminal-3.12.1.jar │ │ ├── jline-terminal-jna-3.12.1.jar │ │ ├── jmx-0.195.jar │ │ ├── jmx-http-0.195.jar │ │ ├── jmx-http-rpc-0.159.jar │ │ ├── jmxutils-1.21.jar │ │ ├── jna-4.2.0.jar │ │ ├── joda-time-2.10.5.jar │ │ ├── joni-2.1.5.3.jar │ │ ├── json-0.195.jar │ │ ├── jsr305-3.0.2.jar │ │ ├── jts-core-1.16.1.jar │ │ ├── leveldb-0.10.jar │ │ ├── leveldb-api-0.10.jar │ │ ├── listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar │ │ ├── log-0.195.jar │ │ ├── log4j-over-slf4j-1.7.29.jar │ │ ├── logback-core-1.2.3.jar │ │ ├── log-manager-0.195.jar │ │ ├── lucene-analyzers-common-8.4.1.jar │ │ ├── lucene-core-8.4.1.jar │ │ ├── maven-aether-provider-3.0.5.jar │ │ ├── maven-artifact-3.0.5.jar │ │ ├── maven-compat-3.0.5.jar │ │ ├── maven-core-3.0.5.jar │ │ ├── maven-embedder-3.0.5.jar │ │ ├── maven-model-3.0.5.jar │ │ ├── maven-model-builder-3.0.5.jar │ │ ├── maven-plugin-api-3.0.5.jar │ │ ├── maven-repository-metadata-3.0.5.jar │ │ ├── maven-settings-3.0.5.jar │ │ ├── maven-settings-builder-3.0.5.jar │ │ ├── netty-3.10.6.Final.jar │ │ ├── node-0.195.jar │ │ ├── objectsize-0.0.12.jar │ │ ├── objenesis-2.6.jar │ │ ├── okhttp-3.9.0.jar │ │ ├── okhttp-urlconnection-3.9.0.jar │ │ ├── okio-1.13.0.jar │ │ ├── opencsv-2.3.jar │ │ ├── osgi-resource-locator-1.0.3.jar │ │ ├── parameternames-1.4.jar │ │ ├── pcollections-2.1.2.jar │ │ ├── plexus-cipher-1.7.jar │ │ ├── plexus-classworlds-2.4.jar │ │ ├── plexus-component-annotations-1.5.5.jar │ │ ├── plexus-container-default-1.5.5.jar │ │ ├── plexus-interpolation-1.14.jar │ │ ├── plexus-sec-dispatcher-1.3.jar │ │ ├── plexus-utils-2.0.6.jar │ │ ├── presto-array-332.jar │ │ ├── presto-cli-332.jar │ │ ├── presto-client-332.jar │ │ ├── presto-geospatial-toolkit-332.jar │ │ ├── presto-main-332.jar │ │ ├── presto-matching-332.jar │ │ ├── presto-memory-context-332.jar │ │ ├── presto-parser-332.jar │ │ ├── presto-plugin-toolkit-332.jar │ │ ├── presto-spi-332.jar │ │ ├── pulsar-presto-distribution-2.8.0.jar │ │ ├── re2j-td-1.4.jar │ │ ├── resolver-1.5.jar │ │ ├── security-0.195.jar │ │ ├── slf4j-api-1.7.25.jar │ │ ├── slf4j-jdk14-1.7.29.jar │ │ ├── slice-0.38.jar │ │ ├── snakeyaml-1.27.jar │ │ ├── stats-0.195.jar │ │ ├── trace-token-0.195.jar │ │ ├── units-1.6.jar │ │ ├── validation-api-2.0.1.Final.jar │ │ ├── wagon-provider-api-2.4.jar │ │ └── xbean-reflect-3.4.jar │ ├── LICENSE │ └── plugin │ └── pulsar-presto-connector │ ├── aircompressor-0.16.jar │ ├── aopalliance-1.0.jar │ ├── aopalliance-repackaged-2.6.1.jar │ ├── async-http-client-2.12.1.jar │ ├── async-http-client-netty-utils-2.12.1.jar │ ├── audience-annotations-0.5.0.jar │ ├── avro-1.10.2.jar │ ├── avro-protobuf-1.10.2.jar │ ├── bcpkix-jdk15on-1.68.jar │ ├── bcprov-ext-jdk15on-1.68.jar │ ├── bcprov-jdk15on-1.68.jar │ ├── bookkeeper-common-4.14.1.jar │ ├── bookkeeper-common-allocator-4.14.1.jar │ ├── bookkeeper-proto-4.14.1.jar │ ├── bookkeeper-server-4.14.1.jar │ ├── bookkeeper-stats-api-4.14.1.jar │ ├── bookkeeper-tools-framework-4.14.1.jar │ ├── bootstrap-0.199.jar │ ├── bouncy-castle-bc-2.8.0-pkg.jar │ ├── bval-jsr-2.0.0.jar │ ├── caffeine-2.6.2.jar │ ├── cglib-nodep-3.3.0.jar │ ├── checker-qual-3.5.0.jar │ ├── circe-checksum-4.14.1.jar │ ├── codahale-metrics-provider-4.14.1.jar │ ├── commons-cli-1.2.jar │ ├── commons-codec-1.10.jar │ ├── commons-collections4-4.1.jar │ ├── commons-compress-1.19.jar │ ├── commons-configuration-1.10.jar │ ├── commons-io-2.8.0.jar │ ├── commons-lang-2.6.jar │ ├── commons-lang3-3.11.jar │ ├── commons-logging-1.2.jar │ ├── configuration-0.199.jar │ ├── cpu-affinity-4.14.1.jar │ ├── dsl-json-1.8.4.jar │ ├── error_prone_annotations-2.5.1.jar │ ├── failureaccess-1.0.1.jar │ ├── gson-2.8.6.jar │ ├── guava-30.1-jre.jar │ ├── guice-4.2.3.jar │ ├── hk2-api-2.6.1.jar │ ├── hk2-locator-2.6.1.jar │ ├── hk2-utils-2.6.1.jar │ ├── httpclient-4.5.13.jar │ ├── httpcore-4.4.13.jar │ ├── http-server-4.14.1.jar │ ├── j2objc-annotations-1.3.jar │ ├── jackson-annotations-2.12.3.jar │ ├── jackson-core-2.12.3.jar │ ├── jackson-databind-2.12.3.jar │ ├── jackson-dataformat-yaml-2.12.3.jar │ ├── jackson-datatype-guava-2.12.3.jar │ ├── jackson-datatype-jdk8-2.12.3.jar │ ├── jackson-datatype-joda-2.12.3.jar │ ├── jackson-datatype-jsr310-2.12.3.jar │ ├── jackson-jaxrs-base-2.12.3.jar │ ├── jackson-jaxrs-json-provider-2.12.3.jar │ ├── jackson-module-jaxb-annotations-2.12.3.jar │ ├── jackson-module-jsonSchema-2.12.3.jar │ ├── jackson-module-parameter-names-2.12.3.jar │ ├── jakarta.activation-api-1.2.2.jar │ ├── jakarta.annotation-api-1.3.5.jar │ ├── jakarta.inject-2.6.1.jar │ ├── jakarta.xml.bind-api-2.3.3.jar │ ├── javassist-3.25.0-GA.jar │ ├── javax.activation-1.2.0.jar │ ├── javax.inject-1.jar │ ├── javax.servlet-api-3.1.0.jar │ ├── javax.ws.rs-api-2.1.jar │ ├── jaxb-api-2.3.1.jar │ ├── jcip-annotations-1.0.jar │ ├── jcl-over-slf4j-1.7.25.jar │ ├── jcommander-1.78.jar │ ├── jctools-core-2.1.2.jar │ ├── jersey-client-2.34.jar │ ├── jersey-common-2.34.jar │ ├── jersey-entity-filtering-2.34.jar │ ├── jersey-hk2-2.34.jar │ ├── jersey-media-json-jackson-2.34.jar │ ├── jersey-media-multipart-2.34.jar │ ├── jetty-http-9.4.42.v20210604.jar │ ├── jetty-io-9.4.42.v20210604.jar │ ├── jetty-security-9.4.42.v20210604.jar │ ├── jetty-server-9.4.42.v20210604.jar │ ├── jetty-servlet-9.4.42.v20210604.jar │ ├── jetty-util-9.4.42.v20210604.jar │ ├── jetty-util-ajax-9.4.42.v20210604.jar │ ├── jmxutils-1.21.jar │ ├── jna-4.2.0.jar │ ├── joda-time-2.10.5.jar │ ├── jol-core-0.2.jar │ ├── json-0.199.jar │ ├── jsr305-3.0.2.jar │ ├── jul-to-slf4j-1.7.25.jar │ ├── log-0.199.jar │ ├── log4j-over-slf4j-1.7.30.jar │ ├── logback-core-1.2.3.jar │ ├── log-manager-0.199.jar │ ├── managed-ledger-2.8.0.jar │ ├── memory-0.8.3.jar │ ├── metrics-core-3.2.5.jar │ ├── metrics-graphite-3.2.5.jar │ ├── metrics-jvm-3.2.5.jar │ ├── mimepull-1.9.13.jar │ ├── netty-buffer-4.1.63.Final.jar │ ├── netty-codec-4.1.63.Final.jar │ ├── netty-codec-dns-4.1.63.Final.jar │ ├── netty-codec-haproxy-4.1.63.Final.jar │ ├── netty-codec-http-4.1.63.Final.jar │ ├── netty-common-4.1.63.Final.jar │ ├── netty-handler-4.1.63.Final.jar │ ├── netty-reactive-streams-2.0.4.jar │ ├── netty-resolver-4.1.63.Final.jar │ ├── netty-resolver-dns-4.1.63.Final.jar │ ├── netty-tcnative-boringssl-static-2.0.38.Final.jar │ ├── netty-transport-4.1.63.Final.jar │ ├── netty-transport-native-epoll-4.1.63.Final-linux-x86_64.jar │ ├── netty-transport-native-unix-common-4.1.63.Final.jar │ ├── netty-transport-native-unix-common-4.1.63.Final-linux-x86_64.jar │ ├── opencsv-2.3.jar │ ├── osgi-resource-locator-1.0.3.jar │ ├── parameternames-1.4.jar │ ├── presto-plugin-toolkit-332.jar │ ├── presto-record-decoder-332.jar │ ├── presto-spi-332.jar │ ├── prometheus-metrics-provider-4.14.1.jar │ ├── protobuf-java-3.11.4.jar │ ├── pulsar-client-admin-api-2.8.0.jar │ ├── pulsar-client-admin-original-2.8.0.jar │ ├── pulsar-client-api-2.8.0.jar │ ├── pulsar-client-original-2.8.0.jar │ ├── pulsar-common-2.8.0.jar │ ├── pulsar-metadata-2.8.0.jar │ ├── pulsar-package-core-2.8.0.jar │ ├── pulsar-presto-connector-original-2.8.0.jar │ ├── pulsar-transaction-common-2.8.0.jar │ ├── reactive-streams-1.0.3.jar │ ├── rocksdbjni-6.10.2.jar │ ├── simpleclient-0.5.0.jar │ ├── simpleclient_common-0.5.0.jar │ ├── simpleclient_hotspot-0.5.0.jar │ ├── simpleclient_servlet-0.5.0.jar │ ├── sketches-core-0.8.3.jar │ ├── slf4j-api-1.7.25.jar │ ├── slf4j-jdk14-1.7.30.jar │ ├── slice-0.38.jar │ ├── snakeyaml-1.27.jar │ ├── snappy-java-1.1.7.jar │ ├── swagger-annotations-1.6.2.jar │ ├── units-1.6.jar │ ├── validation-api-2.0.1.Final.jar │ ├── zookeeper-3.6.3.jar │ └── zookeeper-jute-3.6.3.jar ├── LICENSE ├── licenses │ ├── LICENSE-bouncycastle.txt │ ├── LICENSE-CC0.txt │ ├── LICENSE-CDDL-1.1.txt │ ├── LICENSE-EDL-1.0.txt │ ├── LICENSE-EPL-1.0.txt │ ├── LICENSE-EPL-2.0.txt │ ├── LICENSE-golang.txt │ ├── LICENSE-google-auth-library.txt │ ├── LICENSE-HdrHistogram0.txt │ ├── LICENSE-HdrHistogram.txt │ ├── LICENSE-jbzip2.txt │ ├── LICENSE-jcip.txt │ ├── LICENSE-jfastlz.txt │ ├── LICENSE-JLine.txt │ ├── LICENSE-JSR305.txt │ ├── LICENSE-LevelDB.txt │ ├── LICENSE-libdivsufsort.txt │ ├── LICENSE-protobuf.txt │ ├── LICENSE-SemVer.txt │ ├── LICENSE-SLF4J.txt │ ├── LICENSE-Spotbugs.txt │ ├── LICENSE-Webbit.txt │ └── LICENSE-xz.txt ├── logs │ ├── bookkeeper-server.log │ ├── pulsar-bookie-developer-server.log │ ├── pulsar-bookie-developer-server.out │ ├── pulsar-broker-developer-server.log │ ├── pulsar-broker-developer-server.out │ ├── pulsar.log │ └── pulsar-standalone.log ├── NOTICE └── README 63 directories, 759 files
在pulsar里面conf目录是配置文件夹的地方，整个pulsar由于自带zookeeper，所以我们需要改动，直接启动单机版即可，启动命令是：
./pulsar-daemon start standalone
3）这里我们看下对应的进程
有一个standalone的进程。
4）查看下pulsar启动了哪些端口
netstat -antlp | grep 77552
到此，我们的pulsar单机版就启动完了。
接下来我们安装下pulsar manager工具，主要做pulsar的监控。
1）首先我们还是把pulsar manager下载下来。
cd /mnt/tools wget https://dist.apache.org/repos/dist/release/pulsar/pulsar-manager/pulsar-manager-0.3.0/apache-pulsar-manager-0.3.0-bin.tar.gz tar -zxvf apache-pulsar-manager-0.3.0-bin.tar.gz mv pulsar-manager .. cd .. cd pulsar-manager
2）然后在进行解压
tar -xvf pulsar-manager.tar cp -r dist pulsar-manager cd pulsar-manager
3）把pulsar-manager启动起来
nohup bin/pulsar-manager &
然后访问下：http://192.168.31.30:7750/ui/index.html#/environments
可以登录进来。
4）添加环境
Environment name： dev Service URL: http://192.168.31.30:8080 Bookie URL: http://192.168.31.6650
然后点击这个dev就可以看到具体的情况了
您阅读本篇文章共花了： 
还没有评论，来说两句吧...