大数据系列之：安装pulsar详细步骤

news2024/12/25 13:32:56

大数据系列之：安装pulsar详细步骤

  • 一、Pulsar版本和jdk对应关系
  • 二、安装JDK
  • 三、设置和激活jdk环境变量
  • 四、下载和解压Pulsar
  • 五、查看Pulsar目录
  • 六、启动Pulsar standalone cluster
  • 七、创建Kafka Topic
  • 八、往Topic写入数据
  • 九、消费pulsar的Topic

一、Pulsar版本和jdk对应关系

点击下面的链接查看Pulsar版本和jdk对应关系：

  • https://github.com/apache/pulsar/blob/master/README.md#pulsar-runtime-java-version-recommendation

在这里插入图片描述

二、安装JDK

点击链接下载JDK：

  • https://adoptium.net/temurin/releases/?variant=openjdk17
tar -zxvf OpenJDK17U-jdk_x64_linux_hotspot_17.0.6_10.tar.gz

三、设置和激活jdk环境变量

设置环境变量

vim /etc/profile
export JAVA_HOME="/data/src/jdk17"
PATH=$PATH:$JAVA_HOME/bin

激活环境变量

source /etc/profile

四、下载和解压Pulsar

下载Pulsar

wget https://archive.apache.org/dist/pulsar/pulsar-2.11.0/apache-pulsar-2.11.0-bin.tar.gz

解压Pulsar

tar -zxvf apache-pulsar-2.11.0-bin.tar.gz

五、查看Pulsar目录

cd apache-pulsar-2.11.0
ls 
bin  conf  data  examples  instances  lib  LICENSE  logs  NOTICE  packages-storage  README

六、启动Pulsar standalone cluster

bin/pulsar standalone

2023-02-10T15:19:17,880+0800 [main] INFO  org.apache.pulsar.functions.worker.FunctionRuntimeManager - Initializing secrets provider configurator org.apache.pulsar.functions.secretsproviderconfigurator.DefaultSecretsProviderConfigurator with configs: null
2023-02-10T15:19:17,885+0800 [pulsar-web-48-6] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:19:17 +0800] "GET /admin/v2/persistent/public/functions/coordinate/subscriptions HTTP/1.1" 200 16 "-" "Pulsar-Java-v2.11.0" 19
2023-02-10T15:19:17,888+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/__change_events][reader-6bed90fa36] Successfully getLastMessageId -1:-1
2023-02-10T15:19:17,890+0800 [main] INFO  org.apache.pulsar.functions.runtime.process.ProcessRuntimeFactory - Java instance jar location is not defined, using the location defined in system environment : /data/src/apache-pulsar-2.11.0/instances/java-instance.jar
2023-02-10T15:19:17,890+0800 [main] INFO  org.apache.pulsar.functions.runtime.process.ProcessRuntimeFactory - Python instance file location is not defined using the location defined in system environment : /data/src/apache-pulsar-2.11.0/instances/python-instance/python_instance_main.py
2023-02-10T15:19:17,891+0800 [main] INFO  org.apache.pulsar.functions.runtime.process.ProcessRuntimeFactory - Extra dependencies location is not defined using the location defined in system environment : /data/src/apache-pulsar-2.11.0/instances/deps
2023-02-10T15:19:17,894+0800 [main] INFO  org.apache.pulsar.functions.worker.PulsarWorkerService - /** Start Leader Service **/
2023-02-10T15:19:17,898+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xa5a16e3a, L:/127.0.0.1:10729 - R:localhost/127.0.0.1:6650]] Connected to server
2023-02-10T15:19:17,899+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - New connection from /127.0.0.1:10729
2023-02-10T15:19:17,915+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer status recorder with config: {"topicNames":["persistent://public/functions/coordinate"],"topicsPattern":null,"subscriptionName":"participants","subscriptionType":"Failover","subscriptionProperties":null,"subscriptionMode":"Durable","receiverQueueSize":1000,"acknowledgementsGroupTimeMicros":100000,"negativeAckRedeliveryDelayMicros":60000000,"maxTotalReceiverQueueSizeAcrossPartitions":50000,"consumerName":"c-standalone-fw-localhost-8080:localhost:8080","ackTimeoutMillis":0,"tickDurationMillis":1000,"priorityLevel":0,"maxPendingChunkedMessage":10,"autoAckOldestChunkedMessageOnQueueFull":false,"expireTimeOfIncompleteChunkedMessageMillis":60000,"cryptoFailureAction":"FAIL","properties":{"id":"c-standalone-fw-localhost-8080:localhost:8080"},"readCompacted":false,"subscriptionInitialPosition":"Latest","patternAutoDiscoveryPeriod":60,"regexSubscriptionMode":"PersistentOnly","deadLetterPolicy":null,"retryEnable":false,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"replicateSubscriptionState":false,"resetIncludeHead":false,"keySharedPolicy":null,"batchIndexAckEnabled":false,"ackReceiptEnabled":false,"poolMessages":false,"startPaused":false,"autoScaledReceiverQueueSizeEnabled":false,"topicConfigurations":[],"maxPendingChuckedMessage":10}
2023-02-10T15:19:17,919+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: {"serviceUrl":"pulsar://localhost:6650","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalSeconds":60,"numIoThreads":1,"numListenerThreads":1,"connectionsPerBroker":1,"connectionMaxIdleSeconds":180,"useTcpNoDelay":true,"useTls":false,"tlsKeyFilePath":null,"tlsCertificateFilePath":null,"tlsTrustCertsFilePath":null,"tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreTls":false,"sslProvider":null,"tlsKeyStoreType":"JKS","tlsKeyStorePath":null,"tlsKeyStorePassword":null,"tlsTrustStoreType":"JKS","tlsTrustStorePath":null,"tlsTrustStorePassword":null,"tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"dnsLookupBindAddress":null,"dnsLookupBindPort":0,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null}
2023-02-10T15:19:17,925+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/coordinate][participants] Subscribing to topic on cnx [id: 0xa5a16e3a, L:/127.0.0.1:10729 - R:localhost/127.0.0.1:6650], consumerId 0
2023-02-10T15:19:17,926+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Subscribing on topic persistent://public/functions/coordinate / participants
2023-02-10T15:19:17,928+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Created subscription on topic persistent://public/functions/coordinate / participants
2023-02-10T15:19:17,928+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/coordinate][participants] Subscribed to topic on localhost/127.0.0.1:6650 -- consumer: 0
2023-02-10T15:19:17,929+0800 [main] INFO  org.apache.pulsar.functions.worker.PulsarWorkerService - /** Initializing Metadata Manager **/
2023-02-10T15:19:17,935+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer status recorder with config: {"topicNames":["persistent://public/functions/metadata"],"topicsPattern":null,"subscriptionName":"c-standalone-fw-localhost-8080-function-metadata-tailer-reader-c67f7ce6a3","subscriptionType":"Exclusive","subscriptionProperties":null,"subscriptionMode":"NonDurable","receiverQueueSize":1000,"acknowledgementsGroupTimeMicros":100000,"negativeAckRedeliveryDelayMicros":60000000,"maxTotalReceiverQueueSizeAcrossPartitions":50000,"consumerName":"c-standalone-fw-localhost-8080-function-metadata-tailer","ackTimeoutMillis":0,"tickDurationMillis":1000,"priorityLevel":0,"maxPendingChunkedMessage":10,"autoAckOldestChunkedMessageOnQueueFull":false,"expireTimeOfIncompleteChunkedMessageMillis":60000,"cryptoFailureAction":"FAIL","properties":{},"readCompacted":false,"subscriptionInitialPosition":"Latest","patternAutoDiscoveryPeriod":60,"regexSubscriptionMode":"PersistentOnly","deadLetterPolicy":null,"retryEnable":false,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"replicateSubscriptionState":false,"resetIncludeHead":false,"keySharedPolicy":null,"batchIndexAckEnabled":false,"ackReceiptEnabled":false,"poolMessages":false,"startPaused":false,"autoScaledReceiverQueueSizeEnabled":false,"topicConfigurations":[],"maxPendingChuckedMessage":10}
2023-02-10T15:19:17,939+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: {"serviceUrl":"pulsar://localhost:6650","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalSeconds":60,"numIoThreads":1,"numListenerThreads":1,"connectionsPerBroker":1,"connectionMaxIdleSeconds":180,"useTcpNoDelay":true,"useTls":false,"tlsKeyFilePath":null,"tlsCertificateFilePath":null,"tlsTrustCertsFilePath":null,"tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreTls":false,"sslProvider":null,"tlsKeyStoreType":"JKS","tlsKeyStorePath":null,"tlsKeyStorePassword":null,"tlsTrustStoreType":"JKS","tlsTrustStorePath":null,"tlsTrustStorePassword":null,"tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"dnsLookupBindAddress":null,"dnsLookupBindPort":0,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null}
2023-02-10T15:19:17,941+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata][c-standalone-fw-localhost-8080-function-metadata-tailer-reader-c67f7ce6a3] Subscribing to topic on cnx [id: 0xa5a16e3a, L:/127.0.0.1:10729 - R:localhost/127.0.0.1:6650], consumerId 1
2023-02-10T15:19:17,942+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Subscribing on topic persistent://public/functions/metadata / c-standalone-fw-localhost-8080-function-metadata-tailer-reader-c67f7ce6a3
2023-02-10T15:19:17,942+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.persistent.PersistentTopic - [persistent://public/functions/metadata][c-standalone-fw-localhost-8080-function-metadata-tailer-reader-c67f7ce6a3] Creating non-durable subscription at msg id -1:-1:-1:-1 - {}
2023-02-10T15:19:17,942+0800 [pulsar-io-19-3] INFO  org.apache.bookkeeper.mledger.impl.NonDurableCursorImpl - [public/functions/persistent/metadata] Created non-durable cursor read-position=18:0 mark-delete-position=18:-1
2023-02-10T15:19:17,942+0800 [pulsar-io-19-3] INFO  org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl - [public/functions/persistent/metadata] Opened new cursor: NonDurableCursorImpl{ledger=public/functions/persistent/metadata, ackPos=18:-1, readPos=18:0}
2023-02-10T15:19:17,943+0800 [pulsar-io-19-3] INFO  org.apache.bookkeeper.mledger.impl.ManagedCursorImpl - [public/functions/persistent/metadata-c-standalone-fw-localhost-8080-function-metadata-tailer-reader-c67f7ce6a3] Rewind from 18:0 to 18:0
2023-02-10T15:19:17,943+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Created subscription on topic persistent://public/functions/metadata / c-standalone-fw-localhost-8080-function-metadata-tailer-reader-c67f7ce6a3
2023-02-10T15:19:17,943+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata][c-standalone-fw-localhost-8080-function-metadata-tailer-reader-c67f7ce6a3] Subscribed to topic on localhost/127.0.0.1:6650 -- consumer: 1
2023-02-10T15:19:17,944+0800 [main] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata][c-standalone-fw-localhost-8080-function-metadata-tailer-reader-c67f7ce6a3] Get topic last message Id
2023-02-10T15:19:17,945+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata][c-standalone-fw-localhost-8080-function-metadata-tailer-reader-c67f7ce6a3] Successfully getLastMessageId -1:-1
2023-02-10T15:19:17,949+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Closing consumer: consumerId=1
2023-02-10T15:19:17,949+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://public/functions/metadata, name=c-standalone-fw-localhost-8080-function-metadata-tailer-reader-c67f7ce6a3}, consumerId=1, consumerName=c-standalone-fw-localhost-8080-function-metadata-tailer, address=/127.0.0.1:10729}
2023-02-10T15:19:17,950+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://public/functions/metadata][c-standalone-fw-localhost-8080-function-metadata-tailer-reader-c67f7ce6a3] Successfully closed subscription [NonDurableCursorImpl{ledger=public/functions/persistent/metadata, ackPos=18:-1, readPos=18:0}]
2023-02-10T15:19:17,951+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://public/functions/metadata][c-standalone-fw-localhost-8080-function-metadata-tailer-reader-c67f7ce6a3] Successfully closed dispatcher for reader
2023-02-10T15:19:17,952+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Closed consumer, consumerId=1
2023-02-10T15:19:17,952+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata] [c-standalone-fw-localhost-8080-function-metadata-tailer-reader-c67f7ce6a3] Closed consumer
2023-02-10T15:19:17,954+0800 [main] INFO  org.apache.pulsar.functions.worker.FunctionMetaDataManager - FunctionMetaData Manager initialization complete
2023-02-10T15:19:17,954+0800 [main] INFO  org.apache.pulsar.functions.worker.PulsarWorkerService - /** Initializing Runtime Manager **/
2023-02-10T15:19:17,961+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer status recorder with config: {"topicNames":["persistent://public/functions/assignments"],"topicsPattern":null,"subscriptionName":"c-standalone-fw-localhost-8080-function-assignment-initialize-reader-a8bc01f6ce","subscriptionType":"Exclusive","subscriptionProperties":null,"subscriptionMode":"NonDurable","receiverQueueSize":1000,"acknowledgementsGroupTimeMicros":100000,"negativeAckRedeliveryDelayMicros":60000000,"maxTotalReceiverQueueSizeAcrossPartitions":50000,"consumerName":"c-standalone-fw-localhost-8080-function-assignment-initialize","ackTimeoutMillis":0,"tickDurationMillis":1000,"priorityLevel":0,"maxPendingChunkedMessage":10,"autoAckOldestChunkedMessageOnQueueFull":false,"expireTimeOfIncompleteChunkedMessageMillis":60000,"cryptoFailureAction":"FAIL","properties":{},"readCompacted":true,"subscriptionInitialPosition":"Latest","patternAutoDiscoveryPeriod":60,"regexSubscriptionMode":"PersistentOnly","deadLetterPolicy":null,"retryEnable":false,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"replicateSubscriptionState":false,"resetIncludeHead":false,"keySharedPolicy":null,"batchIndexAckEnabled":false,"ackReceiptEnabled":false,"poolMessages":false,"startPaused":false,"autoScaledReceiverQueueSizeEnabled":false,"topicConfigurations":[],"maxPendingChuckedMessage":10}
2023-02-10T15:19:17,964+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: {"serviceUrl":"pulsar://localhost:6650","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalSeconds":60,"numIoThreads":1,"numListenerThreads":1,"connectionsPerBroker":1,"connectionMaxIdleSeconds":180,"useTcpNoDelay":true,"useTls":false,"tlsKeyFilePath":null,"tlsCertificateFilePath":null,"tlsTrustCertsFilePath":null,"tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreTls":false,"sslProvider":null,"tlsKeyStoreType":"JKS","tlsKeyStorePath":null,"tlsKeyStorePassword":null,"tlsTrustStoreType":"JKS","tlsTrustStorePath":null,"tlsTrustStorePassword":null,"tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"dnsLookupBindAddress":null,"dnsLookupBindPort":0,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null}
2023-02-10T15:19:17,965+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][c-standalone-fw-localhost-8080-function-assignment-initialize-reader-a8bc01f6ce] Subscribing to topic on cnx [id: 0xa5a16e3a, L:/127.0.0.1:10729 - R:localhost/127.0.0.1:6650], consumerId 2
2023-02-10T15:19:17,966+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Subscribing on topic persistent://public/functions/assignments / c-standalone-fw-localhost-8080-function-assignment-initialize-reader-a8bc01f6ce
2023-02-10T15:19:17,967+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.persistent.PersistentTopic - [persistent://public/functions/assignments][c-standalone-fw-localhost-8080-function-assignment-initialize-reader-a8bc01f6ce] Creating non-durable subscription at msg id -1:-1:-1:-1 - {}
2023-02-10T15:19:17,967+0800 [pulsar-io-19-3] INFO  org.apache.bookkeeper.mledger.impl.NonDurableCursorImpl - [public/functions/persistent/assignments] Created non-durable cursor read-position=15:0 mark-delete-position=15:-1
2023-02-10T15:19:17,967+0800 [pulsar-io-19-3] INFO  org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl - [public/functions/persistent/assignments] Opened new cursor: NonDurableCursorImpl{ledger=public/functions/persistent/assignments, ackPos=15:-1, readPos=15:0}
2023-02-10T15:19:17,967+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Created subscription on topic persistent://public/functions/assignments / c-standalone-fw-localhost-8080-function-assignment-initialize-reader-a8bc01f6ce
2023-02-10T15:19:17,968+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][c-standalone-fw-localhost-8080-function-assignment-initialize-reader-a8bc01f6ce] Subscribed to topic on localhost/127.0.0.1:6650 -- consumer: 2
2023-02-10T15:19:17,969+0800 [main] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][c-standalone-fw-localhost-8080-function-assignment-initialize-reader-a8bc01f6ce] Get topic last message Id
2023-02-10T15:19:17,970+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][c-standalone-fw-localhost-8080-function-assignment-initialize-reader-a8bc01f6ce] Successfully getLastMessageId -1:-1
2023-02-10T15:19:17,970+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Closing consumer: consumerId=2
2023-02-10T15:19:17,970+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://public/functions/assignments, name=c-standalone-fw-localhost-8080-function-assignment-initialize-reader-a8bc01f6ce}, consumerId=2, consumerName=c-standalone-fw-localhost-8080-function-assignment-initialize, address=/127.0.0.1:10729}
2023-02-10T15:19:17,970+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://public/functions/assignments][c-standalone-fw-localhost-8080-function-assignment-initialize-reader-a8bc01f6ce] Successfully closed subscription [NonDurableCursorImpl{ledger=public/functions/persistent/assignments, ackPos=15:-1, readPos=15:0}]
2023-02-10T15:19:17,971+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://public/functions/assignments][c-standalone-fw-localhost-8080-function-assignment-initialize-reader-a8bc01f6ce] Successfully closed dispatcher for reader
2023-02-10T15:19:17,971+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Closed consumer, consumerId=2
2023-02-10T15:19:17,971+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments] [c-standalone-fw-localhost-8080-function-assignment-initialize-reader-a8bc01f6ce] Closed consumer
2023-02-10T15:19:17,972+0800 [main] INFO  org.apache.pulsar.functions.worker.PulsarWorkerService - /** Starting Function Assignment Tailer **/
2023-02-10T15:19:17,972+0800 [main] INFO  org.apache.pulsar.functions.worker.FunctionAssignmentTailer - Assignment tailer will start reading from message id -1:-1:-1
2023-02-10T15:19:17,977+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer status recorder with config: {"topicNames":["persistent://public/functions/assignments"],"topicsPattern":null,"subscriptionName":"c-standalone-fw-localhost-8080-function-assignment-tailer-reader-f1cd2d43c3","subscriptionType":"Exclusive","subscriptionProperties":null,"subscriptionMode":"NonDurable","receiverQueueSize":1000,"acknowledgementsGroupTimeMicros":100000,"negativeAckRedeliveryDelayMicros":60000000,"maxTotalReceiverQueueSizeAcrossPartitions":50000,"consumerName":"c-standalone-fw-localhost-8080-function-assignment-tailer","ackTimeoutMillis":0,"tickDurationMillis":1000,"priorityLevel":0,"maxPendingChunkedMessage":10,"autoAckOldestChunkedMessageOnQueueFull":false,"expireTimeOfIncompleteChunkedMessageMillis":60000,"cryptoFailureAction":"FAIL","properties":{},"readCompacted":true,"subscriptionInitialPosition":"Latest","patternAutoDiscoveryPeriod":60,"regexSubscriptionMode":"PersistentOnly","deadLetterPolicy":null,"retryEnable":false,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"replicateSubscriptionState":false,"resetIncludeHead":false,"keySharedPolicy":null,"batchIndexAckEnabled":false,"ackReceiptEnabled":false,"poolMessages":false,"startPaused":false,"autoScaledReceiverQueueSizeEnabled":false,"topicConfigurations":[],"maxPendingChuckedMessage":10}
2023-02-10T15:19:17,980+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: {"serviceUrl":"pulsar://localhost:6650","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalSeconds":60,"numIoThreads":1,"numListenerThreads":1,"connectionsPerBroker":1,"connectionMaxIdleSeconds":180,"useTcpNoDelay":true,"useTls":false,"tlsKeyFilePath":null,"tlsCertificateFilePath":null,"tlsTrustCertsFilePath":null,"tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreTls":false,"sslProvider":null,"tlsKeyStoreType":"JKS","tlsKeyStorePath":null,"tlsKeyStorePassword":null,"tlsTrustStoreType":"JKS","tlsTrustStorePath":null,"tlsTrustStorePassword":null,"tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"dnsLookupBindAddress":null,"dnsLookupBindPort":0,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null}
2023-02-10T15:19:17,981+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][c-standalone-fw-localhost-8080-function-assignment-tailer-reader-f1cd2d43c3] Subscribing to topic on cnx [id: 0xa5a16e3a, L:/127.0.0.1:10729 - R:localhost/127.0.0.1:6650], consumerId 3
2023-02-10T15:19:17,983+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Subscribing on topic persistent://public/functions/assignments / c-standalone-fw-localhost-8080-function-assignment-tailer-reader-f1cd2d43c3
2023-02-10T15:19:17,983+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.persistent.PersistentTopic - [persistent://public/functions/assignments][c-standalone-fw-localhost-8080-function-assignment-tailer-reader-f1cd2d43c3] Creating non-durable subscription at msg id -1:-1:-1:-1 - {}
2023-02-10T15:19:17,983+0800 [pulsar-io-19-3] INFO  org.apache.bookkeeper.mledger.impl.NonDurableCursorImpl - [public/functions/persistent/assignments] Created non-durable cursor read-position=15:0 mark-delete-position=15:-1
2023-02-10T15:19:17,983+0800 [pulsar-io-19-3] INFO  org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl - [public/functions/persistent/assignments] Opened new cursor: NonDurableCursorImpl{ledger=public/functions/persistent/assignments, ackPos=15:-1, readPos=15:0}
2023-02-10T15:19:17,984+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Created subscription on topic persistent://public/functions/assignments / c-standalone-fw-localhost-8080-function-assignment-tailer-reader-f1cd2d43c3
2023-02-10T15:19:17,984+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][c-standalone-fw-localhost-8080-function-assignment-tailer-reader-f1cd2d43c3] Subscribed to topic on localhost/127.0.0.1:6650 -- consumer: 3
2023-02-10T15:19:17,987+0800 [main] INFO  org.apache.pulsar.functions.worker.PulsarWorkerService - /** Starting Metadata Manager **/
2023-02-10T15:19:17,992+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer status recorder with config: {"topicNames":["persistent://public/functions/metadata"],"topicsPattern":null,"subscriptionName":"c-standalone-fw-localhost-8080-function-metadata-tailer-reader-63c4334116","subscriptionType":"Exclusive","subscriptionProperties":null,"subscriptionMode":"NonDurable","receiverQueueSize":1000,"acknowledgementsGroupTimeMicros":100000,"negativeAckRedeliveryDelayMicros":60000000,"maxTotalReceiverQueueSizeAcrossPartitions":50000,"consumerName":"c-standalone-fw-localhost-8080-function-metadata-tailer","ackTimeoutMillis":0,"tickDurationMillis":1000,"priorityLevel":0,"maxPendingChunkedMessage":10,"autoAckOldestChunkedMessageOnQueueFull":false,"expireTimeOfIncompleteChunkedMessageMillis":60000,"cryptoFailureAction":"FAIL","properties":{},"readCompacted":false,"subscriptionInitialPosition":"Latest","patternAutoDiscoveryPeriod":60,"regexSubscriptionMode":"PersistentOnly","deadLetterPolicy":null,"retryEnable":false,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"replicateSubscriptionState":false,"resetIncludeHead":false,"keySharedPolicy":null,"batchIndexAckEnabled":false,"ackReceiptEnabled":false,"poolMessages":false,"startPaused":false,"autoScaledReceiverQueueSizeEnabled":false,"topicConfigurations":[],"maxPendingChuckedMessage":10}
2023-02-10T15:19:17,994+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: {"serviceUrl":"pulsar://localhost:6650","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalSeconds":60,"numIoThreads":1,"numListenerThreads":1,"connectionsPerBroker":1,"connectionMaxIdleSeconds":180,"useTcpNoDelay":true,"useTls":false,"tlsKeyFilePath":null,"tlsCertificateFilePath":null,"tlsTrustCertsFilePath":null,"tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreTls":false,"sslProvider":null,"tlsKeyStoreType":"JKS","tlsKeyStorePath":null,"tlsKeyStorePassword":null,"tlsTrustStoreType":"JKS","tlsTrustStorePath":null,"tlsTrustStorePassword":null,"tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"dnsLookupBindAddress":null,"dnsLookupBindPort":0,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null}
2023-02-10T15:19:17,996+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata][c-standalone-fw-localhost-8080-function-metadata-tailer-reader-63c4334116] Subscribing to topic on cnx [id: 0xa5a16e3a, L:/127.0.0.1:10729 - R:localhost/127.0.0.1:6650], consumerId 4
2023-02-10T15:19:17,996+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Subscribing on topic persistent://public/functions/metadata / c-standalone-fw-localhost-8080-function-metadata-tailer-reader-63c4334116
2023-02-10T15:19:17,997+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.persistent.PersistentTopic - [persistent://public/functions/metadata][c-standalone-fw-localhost-8080-function-metadata-tailer-reader-63c4334116] Creating non-durable subscription at msg id -1:-1:-1:-1 - {}
2023-02-10T15:19:17,997+0800 [pulsar-io-19-3] INFO  org.apache.bookkeeper.mledger.impl.NonDurableCursorImpl - [public/functions/persistent/metadata] Created non-durable cursor read-position=18:0 mark-delete-position=18:-1
2023-02-10T15:19:17,997+0800 [pulsar-io-19-3] INFO  org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl - [public/functions/persistent/metadata] Opened new cursor: NonDurableCursorImpl{ledger=public/functions/persistent/metadata, ackPos=18:-1, readPos=18:0}
2023-02-10T15:19:17,997+0800 [pulsar-io-19-3] INFO  org.apache.bookkeeper.mledger.impl.ManagedCursorImpl - [public/functions/persistent/metadata-c-standalone-fw-localhost-8080-function-metadata-tailer-reader-63c4334116] Rewind from 18:0 to 18:0
2023-02-10T15:19:17,997+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Created subscription on topic persistent://public/functions/metadata / c-standalone-fw-localhost-8080-function-metadata-tailer-reader-63c4334116
2023-02-10T15:19:17,998+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata][c-standalone-fw-localhost-8080-function-metadata-tailer-reader-63c4334116] Subscribed to topic on localhost/127.0.0.1:6650 -- consumer: 4
2023-02-10T15:19:18,003+0800 [main] INFO  org.apache.pulsar.functions.worker.FunctionMetaDataManager - MetaData Manager Tailer started
2023-02-10T15:19:18,007+0800 [main] INFO  org.apache.pulsar.functions.worker.PulsarWorkerService - /** Starting Cluster Service Coordinator **/
2023-02-10T15:19:18,007+0800 [main] INFO  org.apache.pulsar.functions.worker.ClusterServiceCoordinator - /** Starting cluster service coordinator **/
2023-02-10T15:19:18,011+0800 [main] INFO  org.apache.pulsar.functions.worker.PulsarWorkerService - /** Started worker id=c-standalone-fw-localhost-8080 **/
2023-02-10T15:19:18,011+0800 [main] INFO  org.apache.pulsar.broker.PulsarService - Function worker service started
2023-02-10T15:19:18,014+0800 [main] INFO  org.apache.pulsar.packages.management.storage.filesystem.FileSystemPackagesStorage - Packages management filesystem storage initialized on packages-storage
2023-02-10T15:19:18,036+0800 [main] INFO  org.apache.pulsar.broker.PulsarService - messaging service is ready, bootstrap_seconds=4
2023-02-10T15:19:18,036+0800 [main] INFO  org.apache.pulsar.broker.PulsarService - messaging service is ready, bootstrap service port = 8080, broker url= pulsar://localhost:6650, cluster=standalone, configs=org.apache.pulsar.broker.ServiceConfiguration@32c8d67
2023-02-10T15:19:18,042+0800 [main] INFO  org.apache.pulsar.broker.PulsarService - created admin with url http://localhost:8080 
2023-02-10T15:19:18,086+0800 [pulsar-web-48-7] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:19:18 +0800] "GET /admin/v2/clusters HTTP/1.1" 200 14 "-" "Pulsar-Java-v2.11.0" 7
2023-02-10T15:19:18,094+0800 [pulsar-web-48-8] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:19:18 +0800] "GET /admin/v2/tenants HTTP/1.1" 200 19 "-" "Pulsar-Java-v2.11.0" 4
2023-02-10T15:19:18,108+0800 [pulsar-web-48-5] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:19:18 +0800] "GET /admin/v2/namespaces/public HTTP/1.1" 200 37 "-" "Pulsar-Java-v2.11.0" 12
2023-02-10T15:19:18,112+0800 [pulsar-web-48-1] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:19:18 +0800] "GET /admin/v2/clusters HTTP/1.1" 200 14 "-" "Pulsar-Java-v2.11.0" 2
2023-02-10T15:19:18,119+0800 [pulsar-web-48-4] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:19:18 +0800] "GET /admin/v2/tenants HTTP/1.1" 200 19 "-" "Pulsar-Java-v2.11.0" 2
2023-02-10T15:19:18,126+0800 [pulsar-web-48-1] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:19:18 +0800] "GET /admin/v2/namespaces/pulsar HTTP/1.1" 200 17 "-" "Pulsar-Java-v2.11.0" 4
2023-02-10T15:19:18,928+0800 [pulsar-io-19-4] INFO  org.apache.bookkeeper.mledger.impl.ManagedCursorImpl - [public/functions/persistent/coordinate-participants] Rewind from 17:0 to 17:0
2023-02-10T15:19:18,930+0800 [pulsar-external-listener-59-1] INFO  org.apache.pulsar.functions.worker.LeaderService - Worker c-standalone-fw-localhost-8080:localhost:8080 became the leader.
2023-02-10T15:19:18,949+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Starting Pulsar producer perf with config: {"topicName":"persistent://public/functions/assignments","producerName":"c-standalone-fw-localhost-8080-scheduler-manager","sendTimeoutMs":30000,"blockIfQueueFull":true,"maxPendingMessages":0,"maxPendingMessagesAcrossPartitions":0,"messageRoutingMode":"RoundRobinPartition","hashingScheme":"JavaStringHash","cryptoFailureAction":"FAIL","batchingMaxPublishDelayMicros":1000,"batchingPartitionSwitchFrequencyByPublishDelay":10,"batchingMaxMessages":1000,"batchingMaxBytes":131072,"batchingEnabled":false,"chunkingEnabled":false,"chunkMaxMessageSize":-1,"compressionType":"LZ4","initialSequenceId":null,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"multiSchema":true,"accessMode":"Exclusive","lazyStartPartitionedProducers":false,"properties":{},"initialSubscriptionName":null}
2023-02-10T15:19:18,951+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Pulsar client config: {"serviceUrl":"pulsar://localhost:6650","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalSeconds":60,"numIoThreads":1,"numListenerThreads":1,"connectionsPerBroker":1,"connectionMaxIdleSeconds":180,"useTcpNoDelay":true,"useTls":false,"tlsKeyFilePath":null,"tlsCertificateFilePath":null,"tlsTrustCertsFilePath":null,"tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreTls":false,"sslProvider":null,"tlsKeyStoreType":"JKS","tlsKeyStorePath":null,"tlsKeyStorePassword":null,"tlsTrustStoreType":"JKS","tlsTrustStorePath":null,"tlsTrustStorePassword":null,"tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"dnsLookupBindAddress":null,"dnsLookupBindPort":0,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null}
2023-02-10T15:19:18,953+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ProducerImpl - [persistent://public/functions/assignments] [c-standalone-fw-localhost-8080-scheduler-manager] Creating producer on cnx [id: 0xa5a16e3a, L:/127.0.0.1:10729 - R:localhost/127.0.0.1:6650]
2023-02-10T15:19:18,970+0800 [bookkeeper-ml-scheduler-OrderedScheduler-0-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentTopic - [persistent://public/functions/assignments] Updated topic epoch to 1
2023-02-10T15:19:18,972+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Created new producer: Producer{topic=PersistentTopic{topic=persistent://public/functions/assignments}, client=/127.0.0.1:10729, producerName=c-standalone-fw-localhost-8080-scheduler-manager, producerId=0}
2023-02-10T15:19:18,977+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ProducerImpl - [persistent://public/functions/assignments] [c-standalone-fw-localhost-8080-scheduler-manager] Created producer on cnx [id: 0xa5a16e3a, L:/127.0.0.1:10729 - R:localhost/127.0.0.1:6650]
2023-02-10T15:19:18,977+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ProducerImpl - [persistent://public/functions/assignments] [c-standalone-fw-localhost-8080-scheduler-manager] Producer epoch is Optional[1]
2023-02-10T15:19:18,981+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Starting Pulsar producer perf with config: {"topicName":"persistent://public/functions/metadata","producerName":"c-standalone-fw-localhost-8080-leader","sendTimeoutMs":30000,"blockIfQueueFull":true,"maxPendingMessages":0,"maxPendingMessagesAcrossPartitions":0,"messageRoutingMode":"RoundRobinPartition","hashingScheme":"JavaStringHash","cryptoFailureAction":"FAIL","batchingMaxPublishDelayMicros":1000,"batchingPartitionSwitchFrequencyByPublishDelay":10,"batchingMaxMessages":1000,"batchingMaxBytes":131072,"batchingEnabled":false,"chunkingEnabled":false,"chunkMaxMessageSize":-1,"compressionType":"LZ4","initialSequenceId":null,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"multiSchema":true,"accessMode":"Exclusive","lazyStartPartitionedProducers":false,"properties":{},"initialSubscriptionName":null}
2023-02-10T15:19:18,983+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Pulsar client config: {"serviceUrl":"pulsar://localhost:6650","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalSeconds":60,"numIoThreads":1,"numListenerThreads":1,"connectionsPerBroker":1,"connectionMaxIdleSeconds":180,"useTcpNoDelay":true,"useTls":false,"tlsKeyFilePath":null,"tlsCertificateFilePath":null,"tlsTrustCertsFilePath":null,"tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreTls":false,"sslProvider":null,"tlsKeyStoreType":"JKS","tlsKeyStorePath":null,"tlsKeyStorePassword":null,"tlsTrustStoreType":"JKS","tlsTrustStorePath":null,"tlsTrustStorePassword":null,"tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"dnsLookupBindAddress":null,"dnsLookupBindPort":0,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null}
2023-02-10T15:19:18,985+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ProducerImpl - [persistent://public/functions/metadata] [c-standalone-fw-localhost-8080-leader] Creating producer on cnx [id: 0xa5a16e3a, L:/127.0.0.1:10729 - R:localhost/127.0.0.1:6650]
2023-02-10T15:19:18,990+0800 [bookkeeper-ml-scheduler-OrderedScheduler-2-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentTopic - [persistent://public/functions/metadata] Updated topic epoch to 1
2023-02-10T15:19:18,990+0800 [bookkeeper-ml-scheduler-OrderedScheduler-2-0] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Created new producer: Producer{topic=PersistentTopic{topic=persistent://public/functions/metadata}, client=/127.0.0.1:10729, producerName=c-standalone-fw-localhost-8080-leader, producerId=1}
2023-02-10T15:19:18,990+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ProducerImpl - [persistent://public/functions/metadata] [c-standalone-fw-localhost-8080-leader] Created producer on cnx [id: 0xa5a16e3a, L:/127.0.0.1:10729 - R:localhost/127.0.0.1:6650]
2023-02-10T15:19:18,990+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ProducerImpl - [persistent://public/functions/metadata] [c-standalone-fw-localhost-8080-leader] Producer epoch is Optional[1]
2023-02-10T15:19:18,991+0800 [pulsar-external-listener-59-1] INFO  org.apache.pulsar.functions.worker.SchedulerManager - Initializing scheduler manager
2023-02-10T15:19:19,989+0800 [assignment-tailer-thread] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][c-standalone-fw-localhost-8080-function-assignment-tailer-reader-f1cd2d43c3] Get topic last message Id
2023-02-10T15:19:19,990+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][c-standalone-fw-localhost-8080-function-assignment-tailer-reader-f1cd2d43c3] Successfully getLastMessageId -1:-1
2023-02-10T15:19:19,991+0800 [assignment-tailer-thread] INFO  org.apache.pulsar.functions.worker.FunctionAssignmentTailer - assignment tailer thread exiting
2023-02-10T15:19:19,991+0800 [pulsar-external-listener-59-1] INFO  org.apache.pulsar.functions.worker.FunctionAssignmentTailer - Closing function assignment tailer
2023-02-10T15:19:19,991+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Closing consumer: consumerId=3
2023-02-10T15:19:19,991+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://public/functions/assignments, name=c-standalone-fw-localhost-8080-function-assignment-tailer-reader-f1cd2d43c3}, consumerId=3, consumerName=c-standalone-fw-localhost-8080-function-assignment-tailer, address=/127.0.0.1:10729}
2023-02-10T15:19:19,992+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://public/functions/assignments][c-standalone-fw-localhost-8080-function-assignment-tailer-reader-f1cd2d43c3] Successfully closed subscription [NonDurableCursorImpl{ledger=public/functions/persistent/assignments, ackPos=15:-1, readPos=15:0}]
2023-02-10T15:19:19,992+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://public/functions/assignments][c-standalone-fw-localhost-8080-function-assignment-tailer-reader-f1cd2d43c3] Successfully closed dispatcher for reader
2023-02-10T15:19:19,992+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Closed consumer, consumerId=3
2023-02-10T15:19:19,992+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments] [c-standalone-fw-localhost-8080-function-assignment-tailer-reader-f1cd2d43c3] Closed consumer
2023-02-10T15:19:19,992+0800 [pulsar-external-listener-59-1] INFO  org.apache.pulsar.functions.worker.FunctionMetaDataManager - FunctionMetaDataManager becoming leader by creating exclusive producer
2023-02-10T15:19:20,004+0800 [function-metadata-tailer-thread] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata][c-standalone-fw-localhost-8080-function-metadata-tailer-reader-63c4334116] Get topic last message Id
2023-02-10T15:19:20,005+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata][c-standalone-fw-localhost-8080-function-metadata-tailer-reader-63c4334116] Successfully getLastMessageId -1:-1
2023-02-10T15:19:20,005+0800 [function-metadata-tailer-thread] INFO  org.apache.pulsar.functions.worker.FunctionMetaDataTopicTailer - metadata tailer thread exiting
2023-02-10T15:19:20,005+0800 [pulsar-external-listener-59-1] INFO  org.apache.pulsar.functions.worker.FunctionMetaDataTopicTailer - Stopping function metadata tailer
2023-02-10T15:19:20,005+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Closing consumer: consumerId=4
2023-02-10T15:19:20,005+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://public/functions/metadata, name=c-standalone-fw-localhost-8080-function-metadata-tailer-reader-63c4334116}, consumerId=4, consumerName=c-standalone-fw-localhost-8080-function-metadata-tailer, address=/127.0.0.1:10729}
2023-02-10T15:19:20,006+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://public/functions/metadata][c-standalone-fw-localhost-8080-function-metadata-tailer-reader-63c4334116] Successfully closed subscription [NonDurableCursorImpl{ledger=public/functions/persistent/metadata, ackPos=18:-1, readPos=18:0}]
2023-02-10T15:19:20,006+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://public/functions/metadata][c-standalone-fw-localhost-8080-function-metadata-tailer-reader-63c4334116] Successfully closed dispatcher for reader
2023-02-10T15:19:20,006+0800 [pulsar-io-19-3] INFO  org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:10729] Closed consumer, consumerId=4
2023-02-10T15:19:20,006+0800 [pulsar-client-io-58-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata] [c-standalone-fw-localhost-8080-function-metadata-tailer-reader-63c4334116] Closed consumer
2023-02-10T15:19:20,006+0800 [pulsar-external-listener-59-1] INFO  org.apache.pulsar.functions.worker.FunctionMetaDataTopicTailer - Stopped function metadata tailer
2023-02-10T15:19:20,006+0800 [pulsar-external-listener-59-1] INFO  org.apache.pulsar.functions.worker.FunctionMetaDataManager - FunctionMetaDataManager done becoming leader
2023-02-10T15:19:20,043+0800 [ForkJoinPool.commonPool-worker-3] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:19:20 +0800] "GET /admin/v2/persistent/public/functions/coordinate/stats?getPreciseBacklog=false&subscriptionBacklogSize=false&getEarliestTimeInBacklog=false HTTP/1.1" 200 2410 "-" "Pulsar-Java-v2.11.0" 28
2023-02-10T15:19:20,056+0800 [worker-scheduler-0] INFO  org.apache.pulsar.functions.worker.SchedulerManager - Schedule summary - execution time: 0.043905637 sec | total unassigned: 0 | stats: {"Added": 0, "Updated": 0, "removed": 0}
{
  "c-standalone-fw-localhost-8080" : {
    "originalNumAssignments" : 0,
    "finalNumAssignments" : 0,
    "instancesAdded" : 0,
    "instancesRemoved" : 0,
    "instancesUpdated" : 0,
    "alive" : true
  }
}
2023-02-10T15:19:48,014+0800 [ForkJoinPool.commonPool-worker-3] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:19:48 +0800] "GET /admin/v2/persistent/public/functions/coordinate/stats?getPreciseBacklog=false&subscriptionBacklogSize=false&getEarliestTimeInBacklog=false HTTP/1.1" 200 2410 "-" "Pulsar-Java-v2.11.0" 4
2023-02-10T15:19:48,021+0800 [ForkJoinPool.commonPool-worker-3] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:19:48 +0800] "GET /admin/v2/persistent/public/functions/coordinate/stats?getPreciseBacklog=false&subscriptionBacklogSize=false&getEarliestTimeInBacklog=false HTTP/1.1" 200 2410 "-" "Pulsar-Java-v2.11.0" 3
2023-02-10T15:20:18,013+0800 [ForkJoinPool.commonPool-worker-3] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:20:18 +0800] "GET /admin/v2/persistent/public/functions/coordinate/stats?getPreciseBacklog=false&subscriptionBacklogSize=false&getEarliestTimeInBacklog=false HTTP/1.1" 200 2410 "-" "Pulsar-Java-v2.11.0" 3
2023-02-10T15:20:18,020+0800 [ForkJoinPool.commonPool-worker-3] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:20:18 +0800] "GET /admin/v2/persistent/public/functions/coordinate/stats?getPreciseBacklog=false&subscriptionBacklogSize=false&getEarliestTimeInBacklog=false HTTP/1.1" 200 2410 "-" "Pulsar-Java-v2.11.0" 3
2023-02-10T15:20:18,025+0800 [ForkJoinPool.commonPool-worker-3] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:20:18 +0800] "GET /admin/v2/persistent/public/functions/coordinate/stats?getPreciseBacklog=false&subscriptionBacklogSize=false&getEarliestTimeInBacklog=false HTTP/1.1" 200 2410 "-" "Pulsar-Java-v2.11.0" 2
2023-02-10T15:20:48,014+0800 [ForkJoinPool.commonPool-worker-3] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:20:48 +0800] "GET /admin/v2/persistent/public/functions/coordinate/stats?getPreciseBacklog=false&subscriptionBacklogSize=false&getEarliestTimeInBacklog=false HTTP/1.1" 200 2410 "-" "Pulsar-Java-v2.11.0" 3
2023-02-10T15:20:48,019+0800 [ForkJoinPool.commonPool-worker-3] INFO  org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [10/Feb/2023:15:20:48 +0800] "GET /admin/v2/persistent/public/functions/coordinate/stats?getPreciseBacklog=false&subscriptionBacklogSize=false&getEarliestTimeInBacklog=false HTTP/1.1" 200 2410 "-" "Pulsar-Java-v2.11.0" 3

七、创建Kafka Topic

bin/pulsar-admin topics create persistent://public/default/my-topic
(root)[t-qcbj5-hadoop-database-002]{/data/src/apache-pulsar-2.11.0}<test>$ bin/pulsar-client produce my-topic --messages 'Hello Pulsar!'
2023-02-10T15:07:22,363+0800 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x0fe4db59, L:/127.0.0.1:9978 - R:localhost/127.0.0.1:6650]] Connected to server
2023-02-10T15:07:22,489+0800 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Starting Pulsar producer perf with config: {"topicName":"my-topic","producerName":null,"sendTimeoutMs":30000,"blockIfQueueFull":false,"maxPendingMessages":1000,"maxPendingMessagesAcrossPartitions":50000,"messageRoutingMode":"RoundRobinPartition","hashingScheme":"JavaStringHash","cryptoFailureAction":"FAIL","batchingMaxPublishDelayMicros":1000,"batchingPartitionSwitchFrequencyByPublishDelay":10,"batchingMaxMessages":1000,"batchingMaxBytes":131072,"batchingEnabled":true,"chunkingEnabled":false,"chunkMaxMessageSize":-1,"compressionType":"NONE","initialSequenceId":null,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"multiSchema":true,"accessMode":"Shared","lazyStartPartitionedProducers":false,"properties":{},"initialSubscriptionName":null}
2023-02-10T15:07:22,521+0800 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Pulsar client config: {"serviceUrl":"pulsar://localhost:6650/","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalSeconds":60,"numIoThreads":1,"numListenerThreads":1,"connectionsPerBroker":1,"connectionMaxIdleSeconds":180,"useTcpNoDelay":true,"useTls":false,"tlsKeyFilePath":"","tlsCertificateFilePath":"","tlsTrustCertsFilePath":"","tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreTls":false,"sslProvider":null,"tlsKeyStoreType":"JKS","tlsKeyStorePath":"","tlsKeyStorePassword":"*****","tlsTrustStoreType":"JKS","tlsTrustStorePath":"","tlsTrustStorePassword":"*****","tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"dnsLookupBindAddress":null,"dnsLookupBindPort":0,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null}
2023-02-10T15:07:22,536+0800 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ProducerImpl - [my-topic] [null] Creating producer on cnx [id: 0x0fe4db59, L:/127.0.0.1:9978 - R:localhost/127.0.0.1:6650]
2023-02-10T15:07:22,547+0800 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ProducerImpl - [my-topic] [standalone-0-1] Created producer on cnx [id: 0x0fe4db59, L:/127.0.0.1:9978 - R:localhost/127.0.0.1:6650]
2023-02-10T15:07:22,593+0800 [main] INFO  org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - [my-topic] [standalone-0-1] Pending messages: 0 --- Publish throughput: 14.62 msg/s --- 0.00 Mbit/s --- Latency: med: 29.000 ms - 95pct: 29.000 ms - 99pct: 29.000 ms - 99.9pct: 29.000 ms - max: 29.000 ms --- BatchSize: med: 1.000 - 95pct: 1.000 - 99pct: 1.000 - 99.9pct: 1.000 - max: 1.000 --- MsgSize: med: 13.000 bytes - 95pct: 13.000 bytes - 99pct: 13.000 bytes - 99.9pct: 13.000 bytes - max: 13.000 bytes --- Ack received rate: 14.62 ack/s --- Failed messages: 0 --- Pending messages: 0
2023-02-10T15:07:22,598+0800 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ProducerImpl - [my-topic] [standalone-0-1] Closed Producer
2023-02-10T15:07:22,599+0800 [main] INFO  org.apache.pulsar.client.impl.PulsarClientImpl - Client closing. URL: pulsar://localhost:6650/
2023-02-10T15:07:22,622+0800 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ClientCnx - [id: 0x0fe4db59, L:/127.0.0.1:9978 ! R:localhost/127.0.0.1:6650] Disconnected
2023-02-10T15:07:24,636+0800 [main] INFO  org.apache.pulsar.client.cli.PulsarClientTool - 1 messages successfully produced

八、往Topic写入数据

bin/pulsar-client produce my-topic --messages 'Hello Pulsar!'

九、消费pulsar的Topic

bin/pulsar-client consume my-topic -s 'my-subscription' -p Earliest -n 0
2023-02-10T15:07:09,675+0800 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xd3503738, L:/127.0.0.1:9960 - R:localhost/127.0.0.1:6650]] Connected to server
2023-02-10T15:07:09,787+0800 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer status recorder with config: {"topicNames":["my-topic"],"topicsPattern":null,"subscriptionName":"my-subscription","subscriptionType":"Exclusive","subscriptionProperties":null,"subscriptionMode":"Durable","receiverQueueSize":1000,"acknowledgementsGroupTimeMicros":100000,"negativeAckRedeliveryDelayMicros":60000000,"maxTotalReceiverQueueSizeAcrossPartitions":50000,"consumerName":null,"ackTimeoutMillis":0,"tickDurationMillis":1000,"priorityLevel":0,"maxPendingChunkedMessage":10,"autoAckOldestChunkedMessageOnQueueFull":false,"expireTimeOfIncompleteChunkedMessageMillis":60000,"cryptoFailureAction":"FAIL","properties":{},"readCompacted":false,"subscriptionInitialPosition":"Earliest","patternAutoDiscoveryPeriod":60,"regexSubscriptionMode":"PersistentOnly","deadLetterPolicy":null,"retryEnable":false,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"replicateSubscriptionState":false,"resetIncludeHead":false,"keySharedPolicy":null,"batchIndexAckEnabled":false,"ackReceiptEnabled":false,"poolMessages":true,"startPaused":false,"autoScaledReceiverQueueSizeEnabled":false,"topicConfigurations":[],"maxPendingChuckedMessage":10}
2023-02-10T15:07:09,820+0800 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: {"serviceUrl":"pulsar://localhost:6650/","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalSeconds":60,"numIoThreads":1,"numListenerThreads":1,"connectionsPerBroker":1,"connectionMaxIdleSeconds":180,"useTcpNoDelay":true,"useTls":false,"tlsKeyFilePath":"","tlsCertificateFilePath":"","tlsTrustCertsFilePath":"","tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreTls":false,"sslProvider":null,"tlsKeyStoreType":"JKS","tlsKeyStorePath":"","tlsKeyStorePassword":"*****","tlsTrustStoreType":"JKS","tlsTrustStorePath":"","tlsTrustStorePassword":"*****","tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"dnsLookupBindAddress":null,"dnsLookupBindPort":0,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null}
2023-02-10T15:07:09,839+0800 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [my-topic][my-subscription] Subscribing to topic on cnx [id: 0xd3503738, L:/127.0.0.1:9960 - R:localhost/127.0.0.1:6650], consumerId 0
2023-02-10T15:07:09,873+0800 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [my-topic][my-subscription] Subscribed to topic on localhost/127.0.0.1:6650 -- consumer: 0
----- got message -----
key:[null], properties:[], content:Hello Pulsar!
2023-02-10T15:08:09,828+0800 [pulsar-timer-6-1] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - [my-topic] [my-subscription] [4410a] Prefetched messages: 0 --- Consume throughput received: 0.02 msgs/s --- 0.00 Mbit/s --- Ack sent rate: 0.02 ack/s --- Failed messages: 0 --- batch messages: 0 ---Failed acks: 0

至此完成pulsar安装部署

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/338182.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

c#小笔记本-基础

c#小笔记本-基础

c#基本知识一.基础操作1.打印-writeline,write2.输入-readline,readkey二.变量1.折叠代码-#region&#xff0c;#endregion2.变量类型&#xff08;在c语言变量类型上新增的&#xff09;三.常量-const四.转义字符五.显示转换1.括号强转-低精度装高精度2.parse法-作用于字符串3.co…
阅读更多...
实践指南｜如何在 Jina 中使用 OpenTelemetry 进行应用程序的监控和跟踪

实践指南｜如何在 Jina 中使用 OpenTelemetry 进行应用程序的监控和跟踪

随着软件和云技术的普及&#xff0c;越来越多的企业开始采用微服务架构、容器化、多云部署和持续部署模式&#xff0c;这增加了因系统失败而给运维/ SRE / DevOps 团队带来的压力&#xff0c;从而增加了开发团队和他们之间的摩擦&#xff0c;因为开发团队总是想尽快部署新功能&…
阅读更多...
28岁才转行软件测试，目前32了，我的一些经历跟感受

28岁才转行软件测试，目前32了，我的一些经历跟感受

我是92年的&#xff0c;算是最早的90后&#xff0c;现在跟你介绍的时候还恬不知耻的说我是90后&#xff0c;哈哈&#xff0c;计算机专业普通本科毕业。在一个二线城市&#xff0c;毕业后因为自身能力问题、认知水平问题&#xff0c;再加上运气不好&#xff0c;换过多份工作&…
阅读更多...
关于@hide的理解

关于@hide的理解

在上一篇文章《学习HandlerThread》我们提到虽然HandlerThread类里有getThreadHandler()方法得到Handler&#xff0c;但是我们不可能调用到它。因为这个方法用hide注释了 /*** return a shared {link Handler} associated with this thread* hide*/NonNullpublic Handler getT…
阅读更多...
数据一致性

数据一致性

目录一、AOP 动态代理切入方法(1) Aspect Oriented Programming(2) 切入点表达式二、SpringBoot 项目扫描类(1) ResourceLoader 扫描类(2) Map 的 computeIfAbsent 方法(3) 反射几个常用 api① 创建一个测试注解② 创建测试 PO 类③ 反射 api 获取指定类的指定注解信息(4) 返回…
阅读更多...
基于Golang哈希算法监控配置文件变化

基于Golang哈希算法监控配置文件变化

SHA(secure hashing algorithm)表示安全哈希算法.SHA是MD5的修正版本&#xff0c;用于数据摘要和认证。哈希和加密类似&#xff0c;唯一区别是哈希是单项的&#xff0c;即哈希后的数据无法解密。SHA有不同的算法&#xff0c;主要包括SHA-1, SHA-2, SHA-256, SHA-512, SHA-224, …
阅读更多...
1.2.6存储结构-磁盘管理：单缓冲区与双缓冲区读取、流水线周期、计算流水线执行时间

1.2.6存储结构-磁盘管理：单缓冲区与双缓冲区读取、流水线周期、计算流水线执行时间

1.2.6存储结构-磁盘管理&#xff1a;单缓冲区与双缓冲区读取、流水线周期、计算流水线执行时间流水线周期计算流水线执行时间微秒&#xff0c;时间单位&#xff0c;符号μs&#xff08;英语&#xff1a;microsecond &#xff09;&#xff0c;1微秒等于百万分之一秒&#xff08;…
阅读更多...
SpringSecurity的使用与步骤

SpringSecurity的使用与步骤

1、SpringSecurity流程图2、导入坐标<!-- spring-boot-starter-security --> <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-security</artifactId> </dependency> <!-- jjwt…
阅读更多...
生物素-磺基-活性酯,Sulfo-NHS Biotin科研用试剂简介；CAS：119616-38-5

生物素-磺基-活性酯,Sulfo-NHS Biotin科研用试剂简介；CAS：119616-38-5

生物素-磺基-活性酯,Sulfo-NHS Biotin 结构式&#xff1a; ​ 编辑 添加图片注释&#xff0c;不超过 140 字&#xff08;可选&#xff09; 英文名称&#xff1a;Sulfo-NHS-Biotin Sulfosuccinimidyl biotin 中文名称&#xff1a;磺酸基-Biotin-N-琥珀酰亚胺基酯 CAS&…
阅读更多...
自己总结优化代码写法

自己总结优化代码写法

jdk1.7新特性详解 开发期间略知jdk1.7的一些特性&#xff0c;没有真正的一个一个得展开研究&#xff0c;而是需要说明再去查&#xff0c;导致最整个新特性不是特别的清楚&#xff0c;这种情况以后得需要改变了&#xff0c;否则就会变成代码的奴隶。现在正好有时间可以细细的研…
阅读更多...
SpringCloud第二讲 Ribbon负载均衡源码分析

SpringCloud第二讲 Ribbon负载均衡源码分析

前言介绍&#xff1a; 这一讲我们将依据Eureka的负载均衡规则&#xff0c;Eureka的具体服务搭建以及服务注册和服务发现可以参考基于Eureka实现服务注册和服务发现_热爱Java的编程小白的博客-CSDN博客 Eureka的服务搭建之后便可以在这上面进行服务注册&#xff0c;如果存在两个…
阅读更多...
产品权限分析与设计

产品权限分析与设计

目前我们使用的访问控制授权方案&#xff0c;主要有以下4种&#xff1a;DAC自主访问控制ACL 访问控制列表MAC强制访问控制RBAC 基于角色的访问控制笔者将拆解和分析这4种权限管理方案的逻辑&#xff0c;并告诉你&#xff0c;这4种权限分别可以运用在什么样的场景中&#xff0c;…
阅读更多...
不能注册？让小白也能使用【ChatGPT】

不能注册？让小白也能使用【ChatGPT】

ChatGPT介绍最近ChatGPT可谓是非常火爆&#xff0c;使得互联网各界人士都备受关注&#xff0c;如果你还不了解ChatGPT,那你真的有点落后了哈。 简单介绍一下ChatGPTChatGPT是由美国人工智能OpenAI研究开发的一种全新聊天机器人模型&#xff0c;它能够通过学习和理解人类的语言跟…
阅读更多...
研一寒假C++复习笔记--左值和右值的理解和使用

研一寒假C++复习笔记--左值和右值的理解和使用

目录 1--左值和右值的定义 2--简单理解左值和右值的代码 3--非const引用只能接受左值 1--左值和右值的定义 左值&#xff1a;L-Value&#xff0c;L理解为 Location&#xff0c;表示可寻&#xff1b; 右值&#xff1a;R-Value&#xff0c;R理解为 Read&#xff0c;表示可读&a…
阅读更多...
Windows 安装appium环境

Windows 安装appium环境

1 windows Appium环境 1.1 安装Node.js Node.js的安装相对简单,下载安装包安装&#xff08;安装包node-v19.6.0-x64.msi&#xff09;, nodejs 安装 然后一路狂点下一步就可以了 安装完成后,在终端中输入node -v,显示版本号则表示安装成功 node-v16.13.1 1.2 JDK安装及环境变…
阅读更多...
路由器刷固件

路由器刷固件

前言 我希望可以远程访问我的电脑。但&#xff0c;我不希望电脑总是处于运行状态&#xff0c;因为那样比较费电。所以需要一个方案&#xff0c;能将睡眠/关机中的电脑唤醒。 方案一&#xff1a;选用智能插座&#xff0c;远程给电脑上电。电脑设置上电自启。但&#xff0c;这存…
阅读更多...
试题 算法训练 N皇后问题(明确清晰)

试题 算法训练 N皇后问题(明确清晰)

试题 算法训练 N皇后问题 提交此题 评测记录 资源限制 内存限制&#xff1a;256.0MB C/C时间限制&#xff1a;100ms Java时间限制&#xff1a;300ms Python时间限制&#xff1a;500ms 问题描述 　　在N*N的方格棋盘放置了N个皇后&#xff0c;使得它们不相互攻击&#xff08;即…
阅读更多...
色彩-基础理论

色彩-基础理论

颜色三大指标 色相 色相是颜色的一个属性&#xff0c;只有黑白灰没有色相这个属性(那银灰色是什么&#xff1f;) 颜色的相貌&#xff0c;指的也是给颜色一个名字 例如&#xff1a;暗红、酒红、土黄、墨绿 饱和度 颜色的鲜艳程度 纯度 饱和度主要取决于含色成分和消色成分&a…
阅读更多...
IDE2022源码编译tomcat

IDE2022源码编译tomcat

因为学习需要&#xff0c;我需要源码编译运行tomcat对其源码进行一个简单的追踪分析。由于先前并未接触过java相关的知识&#xff0c;安装阻力巨大。最后请教我的开发朋友才解决了最后的问题。将其整理出来&#xff0c;让大家能够快速完成相关的部署。本文仅解决tomcat-8.5.46版…
阅读更多...
tensorflow.js 视频图片多目标检测

tensorflow.js 视频图片多目标检测

前言&#xff1a;Tensorflow.js 官方提供了很多常用模型库&#xff0c;涵盖了平时开发中大部分场景的模型。例如&#xff0c;前面提到的图片识别&#xff0c;除此之外还有人体姿态识别&#xff0c;目标物体识别&#xff0c;语音文字等识别。其中一些可能是 Python 转换而来&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023