Apache Pulsar异步消费者设置(可完成的未来)
Apache Pulsar是一个开源的分布式消息系统，具有高可扩展性和可靠性。它支持异步消费者设置，可以实现未来的可完成性。
异步消费者设置是指在消息系统中，消费者可以以异步的方式接收和处理消息。这种设置可以提高系统的吞吐量和性能，并且能够更好地处理高并发的情况。
Apache Pulsar提供了灵活的异步消费者设置选项，包括以下几个方面：
- 消费者模式：Apache Pulsar支持多种消费者模式，包括独占模式、共享模式和故障转移模式。独占模式下，每个消费者独占一部分消息；共享模式下，多个消费者共同消费消息；故障转移模式下，消费者可以自动接管其他消费者的工作。
- 消费者组：Apache Pulsar允许将多个消费者组织成一个组，以便实现负载均衡和故障转移。消费者组内的消费者可以共同消费消息，并且在某个消费者故障时，其他消费者可以接管其工作，确保消息的可靠性和高可用性。
- 消费者位移：Apache Pulsar可以跟踪每个消费者在消息流中的位置，以便实现精确的消费者位移管理。消费者可以随时获取其当前的位移，并且可以手动提交位移或者自动提交位移。
- 消费者优先级：Apache Pulsar支持为消费者设置优先级，以便优先处理重要的消息。消费者可以根据消息的重要性进行优先级排序，并且可以确保高优先级消息的及时处理。
- 异步处理：Apache Pulsar的异步消费者设置可以使消费者以非阻塞的方式接收和处理消息。这种异步处理方式可以提高系统的吞吐量和响应速度，并且能够更好地应对高并发的情况。
推荐的腾讯云相关产品：腾讯云消息队列 CMQ（Cloud Message Queue），是腾讯云提供的一种高可靠、高可用、高性能的分布式消息队列服务。CMQ可以与Apache Pulsar结合使用，实现异步消息传递和处理。
更多关于腾讯云消息队列 CMQ的信息，请访问：腾讯云消息队列 CMQ产品介绍
相关·内容
2回答
我在我的本地机器上运行apache-pulsar单机版，作为队列系统的docker容器，并将1000个作业推送到一个主题(假设是“demo”)。 如果我有1个消费者在听“演示”主题，处理作业并确认(在100ms -500ms内)。所有的工作在大约80秒内完成。 但如果我用更多的消费者(2或4个消费者)做同样的1000个作业测试，总吞吐量保持不变，大约80秒。 我不确定我是否遗漏了一些所需的配置，或者是否需要多个pulsar brokers，或者我应该如何做，以便如果我增加消费者，消费吞吐量也应该增加(例如在2个消费者的情况下大约40-45秒)。 Docker图像: apachepulsar/
浏览 26提问于2019-12-18得票数 2
https://pulsar.apache.org/api/client/2.4.0/org/apache/pulsar/client/api/Consumer.html#seek-long- 在消费者上调用seek(long timestamp)方法时，时间戳是否必须等于消息发布的确切时间？例如，如果我在t=1，5，7发送了三条消息，如果我调用consumer.seek(3)，我会得到一个错误吗？或者我的消费者会被重置为t=3，这样如果我调用consumer.next()，我就会得到第二条消息？ 提前谢谢你，
浏览 83提问于2020-10-26得票数 2
回答已采纳
1回答
我是Apache Pulsar的新手，但我正在尝试使用Pulsar-Functions来处理某个主题的现有消息。这些函数似乎仅用于流式传输，因此只有在新消息到达输入主题时才会触发它们。不过，我还是想确认一下。 谢谢!
浏览 12提问于2021-08-06得票数 0
假设我有一个publisher应用程序，它运行并发布了20条消息，然后就关闭了。
import org.apache.pulsar.client.api.Producer;
import org.apache.pulsar.client.api.PulsarClient;
import org.apache.pulsar.client.api.PulsarClientException;
public class TestPub {
public static void main(String[] args) throws PulsarClientException, Interru
浏览 4提问于2022-03-02得票数 1
我正在为Apache使用Java用户，而我的应用程序不会启动。
我们核实了以下内容：
脉冲星令牌是正确的。我们可以使用telnet和curl命令命中目标SSL端口(6651)，所以它不是防火墙或网络问题角色在Pulsar 中有足够的权限，我们正在为正确的Pulsar集群命中正确的端点，我们在这个环境中使用正确的信任证书<code>F 211</code>
我们还可以使用此客户端代码从另一个环境中再现该问题：
import org.apache.pulsar.client.api.PulsarClient;
PulsarClient client = PulsarClie
浏览 1提问于2021-07-27得票数 0
我有一个Java客户端客户端正在接收Pulsar (v2.10.0) AVRO消息(雇员)，如下所示：
import org.apache.pulsar.client.api.Consumer;
import org.apache.pulsar.client.api.Message;
import org.apache.pulsar.client.api.PulsarClient;
import org.apache.pulsar.client.api.PulsarClientException;
import org.apache.pulsar.client.api.Schema;
impo
浏览 2提问于2022-05-31得票数 2
我尝试在共享模式下使用多个用户在订阅上运行Apache pulsar客户端。多个使用者在多个线程中运行。但是在尝试取消订阅消费者时，收到的错误消息是“未连接或共享的消费者正在尝试取消订阅”。 不能取消订阅共享订阅吗？如何做到这一点？
浏览 87提问于2021-10-08得票数 1
我正在尝试使用Apache Pulsar编写一个多租户(多名称空间)系统。我似乎无法实现的是使用单个客户端/连接发布到这些命名空间中的多个命名空间和主题。消费者方面也是如此。从本质上讲，我希望使用单个应用程序实例能够发布到多个名称空间和主题，而使用一个消费者应用程序能够在消费时做到这一点。我只是想知道这是否可能。
我不想为M个命名空间和每个命名空间的N个主题维护M*N个连接。我看到pulsar中支持正则表达式，但是如果我想单独使用每个主题，那么在消费者端这意味着什么(我会从匹配正则表达式的所有主题得到混合的消息吗?)
浏览 4提问于2020-01-29得票数 4
雅虎开发了Pulsar，pub-sub消息系统，并使其开源。它现在是Apache的孵化项目。因为Kafka也用于相同的目的。想知道，卡夫卡相对于脉冲星的主要正负点。
浏览 1提问于2017-09-05得票数 56
我在Go代码中引用了一个包为：
github.com/apache/pulsar/pulsar-function-go/pf
但是，在构建用于设置集成测试的坞映像时，我需要包括对该库的一些本地更改。
在我的Dockerfile中，我设置了GOPATH和GOROOT，路径如下：
ENV GOROOT /usr/local/go
ENV GOPATH /go
ENV PATH /go/bin:$PATH
然后，在Dockerfile中，我将源代码复制到Docker映像中，并尝试安装Go模块，如下所示：
COPY target/pulsar-function-go/ /pulsar/dependen
浏览 4提问于2020-01-23得票数 0
我可以使用以下docker命令运行Apache Pulsar： docker run -it \
-p 6650:6650 \
-p 8080:8080 \
--mount source=pulsardata,target=/pulsar/data \
--mount source=pulsarconf,target=/pulsar/conf \
apachepulsar/pulsar:2.6.0 \
bin/pulsar standalone 我正在尝试将其转换为docker-compose，并使用下面的docker-compose.yml文件。当我运行该命令时：
浏览 210提问于2020-10-10得票数 0
我有一个Maven依赖项pulsar-log4j2-appender，我对它进行了派生并更改了源代码，因为它在我的项目中抛出了异常。 在更改源代码之后，我运行maven package命令来构建jar，并将其导入到我的项目中(在Intellij：Project Structure | Modules | Dependencies | Add JARs or directories...)中。 但是，当我运行应用程序时，它似乎找不到那个依赖项，因为我在log4j2.xml文件中声明的Pulsar附加器没有配置。 我是否正确地导入了JAR？我想知道JAR是否需要在org.apache.pulsa
浏览 47提问于2020-08-06得票数 2
Flink数据管道从Apache分区主题中读取。我已经将PulsarSource订阅设置为SubscriptionType.Exclusive。当它被更改为SubscriptionType.Shared时，它期望为命名空间启用事务策略。然后在代理中启用事务管理器并启动它。但还是得到了这个例外
Caused by: java.io.IOException: org.apache.flink.util.FlinkRuntimeException: java.util.concurrent.ExecutionException: org.apache.pulsar.client.api.transa
浏览 16提问于2022-05-28得票数 0
我正在尝试运行一个脉冲星DebeziumPostgresSource连接器。
这是我正在运行的命令：
bin/pulsar-admin \
--admin-url https://localhost:8443 \
--auth-plugin org.apache.pulsar.client.impl.auth.AuthenticationToken \
--auth-params file:///pulsar/tokens/broker/token \
--tls-allow-insecure \
source localrun \
--broker-service
浏览 24提问于2020-11-05得票数 2
回答已采纳
1回答
我正在尝试将Apache设置为log4j2的一个附录。这里没有太多的文档，但是我在这里找到了一些例子。
我已经建立了一个玩具示例，在这个示例中，生产者正在记录单个消息，并且在Pulsar服务器上订阅了同一个主题并侦听消息。消费者收到了一些东西，但没有收到我所期望的信息：
Message sent: Test message
Message received: 18:05:27.510 [pulsar-client-io-5-1] INFO org.apache.pulsar.client.impl.ConsumerImpl
Message received: 18:05:27.510 [ma
浏览 5提问于2020-06-24得票数 3
回答已采纳
我可以在本地机器上作为码头集装箱单独运行apache-脉冲星。
docker-compose.yml
脉冲星-独立:图像:apachepulsar/脉冲星端口：- " 8080 :8080“公开：-8080- 6650环境：- PULSAR_MEM=”-Xms512m -Xmx512m -XX:MaxDirectMemorySize=1g“命令：> /bin/bash -c "bin/apply-config-from-env.py conf/standalone.conf && bin/pulsar独立”
有人能让我知道如何运行相同的多代理设置吗
浏览 8提问于2019-12-18得票数 0
在我的k8s集群上，在我的M1 Mac上的桌面上，登录到时遇到了问题。
当我尝试登录时，我无法使用默认的脉冲星管理凭据通过登录页面，当我检查该页面时会看到以下内容：
Failed to load resource: the server responded with a status of 404 (Not Found)
我认为这个问题与我无法通过端口7750连接后台服务有关，但老实说，我不知道如何解决这个问题。我使用helm图表进行部署，并使用minikube.yaml文件值来保持副本计数等，因为它运行在单一的destop节点上。
是否有人在此之前遇到过这个问题，或知道一个解决方案？如果这个
浏览 29提问于2022-01-27得票数 0
1回答
我目前正致力于在Minikube中安装Pulsar。安装似乎进行得很顺利，但是最后当我尝试获取HTTP代理URL和二进制代理URL时...我收到一条错误消息，指出我没有指定有效的服务： xyz-MBP:pulsar xyz$ kubectl get services -n pulsar | grep pulsar-mini-proxy
pulsar-mini-proxy LoadBalancer 10.107.193.52 <pending> 80:31241/TCP,6650:32025/TCP 8h
xyz-MBP:
浏览 36提问于2021-10-19得票数 0
回答已采纳
我正在尝试运行新的apache脉冲星Lakehouse Sink Connector，并获得java.lang.IllegalArgumentException。
下面是我的设置。docker-compose.yaml文件：
version: '3.7'
volumes:
mssql-data:
minio-data:
networks:
oentity:
driver: bridge
services:
pulsar:
image: apachepulsar/pulsar:latest
command: bin/pulsar stand
浏览 19提问于2022-09-20得票数 1
回答已采纳
我独立安装了阿帕奇脉冲星。脉冲星有时会超时。它与高吞吐量无关，也与特定主题(遵循日志)无关。Pulsar-admin代理健康检查返回OK或timeout。如何进行调查？ 10:46:46.365 [pulsar-ordered-OrderedExecutor-7-0] WARN org.apache.pulsar.broker.service.BrokerService - Got exception when reading persistence policy for persistent://nnx/agent_ns/action_up-53da8177-b4b9-4b92-8f75
浏览 86提问于2020-03-24得票数 1
我正在尝试为Apache Pulsar设置一个异步消费者，但我的问题是只收到一条消息，除非我重新启动Spring Boot应用程序，否则没有其他消息。不幸的是，关于在脉冲星上使用CompletableFuture的文档不是很好，我还是个新手。 我的代码如下： @EventListener(ApplicationReadyEvent.class)
public void subscribe() throws PulsarClientException {
Consumer consumer = this.pulsarClient.newConsumer(JSONSchema.of(Tenan
浏览 111提问于2021-04-20得票数 1
回答已采纳
为了进行测试，我设法运行了一个嵌入式独立pulsar服务器和客户端。我还可以发送和接收消息。然而，我实际上想(集成-)测试功能(实现org.apache.pulsar.functions.api.Function)。如何在嵌入式设置中注册函数？ package kic.data.stream.pulsar
import groovy.util.logging.Log
import org.apache.pulsar.PulsarStandalone
import org.apache.pulsar.PulsarStandaloneBuilder
import org.apache.puls
浏览 26提问于2019-06-09得票数 1
回答已采纳
1回答
在执行下面的代码时，使用java中的apache连接到apache。在束流管道中加入脉冲星客户端时，误差小于误差。
梁版本2.40，2.41 javaSE 1.8
import java.io.*;
import org.apache.beam.sdk.*;
import org.apache.beam.io.pulsar.*;
import org.apache.beam.sdk.options.*;
import org.apache.beam.sdk.transforms.*;
import org.apache.beam.sdk.values.*;
import org.apache.
浏览 10提问于2022-10-03得票数 1
腾讯云控制台的接入地址协议为http，设置后报错
Invalid scheme 'http'. Expected 'pulsar' or 'pulsar+ssl'
看sdk文档需要pulsar协议 Pulsar Java client | Apache Pulsar
要使用客户端库连接到 Pulsar，您需要指定一个Pulsar 协议URL。
浏览 79提问于2022-12-14
1回答
我在AvroSchema中有一个疑问，我正在创建一个java程序，它有一个生产者是模式的类型，这行生产者= pulsarClient.newProducer(AvroSchema.of(Foo.class)).topic("test_topic").create()；的newProducer方法的第一个参数是模式，在这里，我们正在传递一个AvroSchema的Foo类，但它的错误AvroSchema无法解决。 import java.util.concurrent.TimeUnit;
import org.apache.pulsar.client.api.Consumer;
浏览 26提问于2019-03-13得票数 0
1回答
我正在尝试实现一个具有多个生产者的Pulsar客户端，它在线程之间分配负载，但是不管在ioThreads()和listenerThreads()上传递的值是什么，它总是重载第一个线程(> 65% cpu，而其他线程完全空闲)。 我已经尝试了一些方法，包括每小时进行一次“动态重新平衡”(最后一种方法)，但在过程中关闭它肯定不是最好的方法。 这是相关的代码 ...
// pulsar client
pulsarClient = PulsarClient.builder() //
.operationTimeout(config.getA
浏览 75提问于2021-11-08得票数 1
回答已采纳
我正在尝试用java编写一个脉冲星客户端，但是我在记录器(Slf4j)中出现了一个错误。我认为这是因为我的PropertyConfigurator制作不好，但是即使我使用defaultConfigurator，也会得到同样长的错误.当我试图让我的PulsarClient变成这样的时候，它就坏了：
this.client = PulsarClient.builder()
.serviceUrl(config.get("target"))
.authentication(AuthenticationFactory.token(
浏览 18提问于2022-09-24得票数 0
回答已采纳
我正在尝试使用Apache Pulsar的重复数据删除功能。 standalone.conf文件中设置了brokerDeduplicationEnabled=true，但是当我从生产者多次发送相同的消息时，我在消费者端得到了所有的消息，这是预期的行为吗？ 重复数据删除不就是AWS SQS中的content based deduplication吗？ 下面是我的生产者代码以供参考。 import pulsar
import json
client = pulsar.Client('pulsar://localhost:6650')
producer = cli
浏览 73提问于2021-08-18得票数 1
回答已采纳
我有一个使用Ignite的复杂项目，并安装了Ignite版本的log4j2。
我还想将安装到log4j2，但是，当我启动应用程序时，我会得到以下错误：
log4j:WARN No appenders could be found for logger (org.apache.pulsar.shade.io.netty.util.internal.logging.InternalLoggerFactory).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.o
浏览 6提问于2020-07-28得票数 1
回答已采纳
1回答
为了消费来自Kafka的数据，我们可以在一个主题上有多个消费者，完全解耦。那么，在卡夫卡和脉冲星之间存在差异的页面上的no shared consumption (https://streaml.io/blog/pulsar-streaming-queuing)是什么意思？
浏览 19提问于2019-04-26得票数 2
回答已采纳
在Pulsar Python客户端中，有订阅者选项unacked_messages_timeout_ms来设置未确认消息重新发送的时间间隔。 与Pulsar Go客户端相当的是什么？ Python py_consumer = client.subscribe(
topic='my-topic',
subscription_name="py-subscriber",
unacked_messages_timeout_ms=10000,
consumer_type=pulsar.ConsumerType.Shared
) 戈
浏览 43提问于2021-08-31得票数 0
回答已采纳
我试图通过java执行apache pulsar生产者和消费者程序，我在GCP虚拟机上安装了apache-pulsar standalone，并在独立模式下启动了集群。下一步是我已经在windows eclipse中给出了一个maven build和我在GCP机器上上传的同一个jar文件，当我在windows eclipse中执行生产者和消费者程序时，我得到了连接被拒绝的错误，这是显而易见的，因为pulsar没有安装在windows机器上。但是，当我在GCP实例中尝试同样的事情时，即使集群已经启动，我也得到了错误，这与没有找到类定义错误有关。 pom.xml >>> <
浏览 344提问于2019-02-10得票数 1
我正在开发一个使用log4j2的Ignite版本的复杂应用程序。它运行得非常好，但是当我试图添加一个Pulsar 时，它会抛出一个错误：
log4j:WARN No appenders could be found for logger (org.apache.pulsar.shade.io.netty.util.internal.logging.InternalLoggerFactory).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4
浏览 0提问于2020-07-24得票数 0
回答已采纳
我正在尝试为Pulsar设置Zookeeper集群。我正在按照here的说明进行操作，但是我总是失败。 在我的设置中，我有两个节点，它们应该是集群的一部分。由于我需要将bookie部署到相同的节点，因此我执行了 $ PULSAR_EXTRA_OPTS="-Dstats_server_port=8001" bin/pulsar-daemon start zookeeper 启动zookeeper。之后，我尝试使用以下命令初始化集群： bin/pulsar initialize-cluster-metadata \
--cluster pulsar-cluster-1 \
浏览 123提问于2019-09-02得票数 0
在我的Pulsar消费者/生产者中，当我试图连接到Pulsar时，我会收到以下错误消息：
org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException： java.util.concurrent.CompletionException: org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(.)失败:连接被拒绝: puls
浏览 1提问于2020-06-11得票数 0
我正在使用Apache Pulsar，并试图部署一个Pulsar函数，但我得到了这个错误： org.apache.pulsar.broker.web.RestException: Policies not found for myTenant/myNamespace namespace 我已经检查了函数中的代码，一切看起来都很正常。我使用的是Pulsar 2.6.0，但我尝试了其他版本，并获得了相同的结果。 是什么导致了这个问题？我该如何解决它？
浏览 152提问于2021-04-13得票数 1
我有一个应用程序，该应用程序在特定主题下向Pulsar生成消息，并在该应用程序完成后关闭该应用程序；同时，不存在用于读取该主题的使用者。
过了一段时间，当我创建一个使用者并想要读取写入的数据时，我发现所有的数据都丢失了，因为我编写的主题被Pulsar删除了。
如何在Pulsar中禁用非活动主题的自动删除？
浏览 0提问于2019-07-24得票数 4
回答已采纳
我正在尝试使用pulsar go客户端，使用go模块，但无法使用正确的版本导入。
创建了一个带有脉冲星依赖项的go.mod文件，还添加了其他依赖项，之前我使用的是dep，一切都很好。现在我转到了go模块，除了pulsar dependency，其他的包都很好，我不确定我错过了什么。
module sample
go 1.13
require github.com/apache/pulsar/pulsar-client-go/pulsar v2.4.1
需要github.com/apache/pulsar/pulsar-client-go:版本"v2.4.1“无效:未知版本pul
浏览 0提问于2019-10-28得票数 1
我已经从Run Pulsar locally在Ubuntu18.04.2LTS上安装了apache pulsar standalone v2.3。它不需要任何身份验证就能正常工作。我尝试过使用security-tls-transport和security-tls-authentication配置tls证书。我已经按照链接中提到的修改了以下配置broker.conf，client.conf和standalone.conf。使用命令bin/pulsar standalone运行脉冲星，并使用下面的命令发送消息。 bin/pulsar-client produce my-topic --messa
浏览 162提问于2019-04-03得票数 1
我不能得到一个简单的hello-world类型的Spring Boot应用程序来利用Pulsar Log4j2附加器。在启动时，它会报告错误：
2021-05-14T15:34:23.549-05:00 pulsar-client-io-6-1错误pulsar -client-io-6-1错误o.a.p.c.i.ProducerImpl applog-json无法创建生产者:名为'pulsar-log4j2-appender-applog-json‘的Producer已连接到主题2021-05-14 15:34:23,550主错误无法启动pulsar管理器pulsar manager
浏览 3提问于2021-05-15得票数 1
这里是Java 8和SpringBoot2.x。我有一个RESTful资源，它将启动一个长期运行的操作，在某些情况下可能需要15-20分钟才能完成。我想我想在服务层中利用@Async注释，但是我对任何优秀的、优雅的Spring解决方案都很开放！
到目前为止，我最大的努力是：
@RestController
@RequestMapping(path = "/v1/fizzbuzzes")
public class FizzbuzzResource {
@Autowired
private FizzbuzzService fizzbuzzService;
浏览 4提问于2020-01-22得票数 0
回答已采纳
我很好奇如何每10秒循环一次代码的这一部分。
我如何才能做到这一点，而不是不一致的API私人消息您的价格！价格执行，而不是正常的消息它在通道中？
import requests
import discord
import asyncio
url = 'https://cryptohub.online/api/market/ticker/PLSR/'
response = requests.get(url)
data = response.json()['BTC_PLSR']
client = discord.Client()
@client.event
a
浏览 1提问于2018-02-14得票数 0
回答已采纳
2回答
我在AWS EKS中使用舵机图表安装了apache脉冲星，
参考资料：
还启用了脉冲星管理器和部署的脉冲星管理器用户界面，所有吊舱都已启动并运行，当我在浏览器中使用负载均衡器外部IP打开脉冲星管理器UI时，manager UI正在加载，但无法使用默认用户名和密码登录，也无法获得CSRF令牌。
当我做卷曲时，从脉冲星管理器pulsar管理器得到404找不到错误: v0.3.0
CSRF_TOKEN=$(curl http://pulsar-load-balancer-ip:9527/pulsar-manager/csrf-token)
浏览 23提问于2022-09-23得票数 1
2回答
我目前正在使用Apache Pulsar，它是从本地Minikube集群上的舵图安装的。安装过程很顺利，Apache Pulsar运行得也很好。然而，每当我关闭/重新启动我的笔记本电脑时，我再也不能让所有的pod运行起来。我总是得到CrashLoopBackOff状态。在重启机器时，我尝试使用以下命令重启Pulsar集群(minikube start)：
xyz-MBP:~ xyz$ minikube start
minikube v1.23.2 on Darwin 11.4
Kubernetes 1.22.2 is now available. If you would like t
浏览 43提问于2021-10-21得票数 0
我正试图从脉冲星的话题中吸取经验。下面可以看到我的客户端代码。但是，我面对的是NoClassDefFoundError。请告诉我如何解决这个问题。
脉冲星客户端版本: 2.10，脉冲星服务器版本: 2.10，安装类型:独立(非码头)，操作系统: Ubuntu 20.04.4 LTS
我的脉冲星客户端代码：
private static void consumeFromPulsarAsync() throws Exception {
logger.info("consumeFromPulsarAsync()");
PulsarClient client = P
浏览 3提问于2022-05-10得票数 1
是否有一种方法可以使用Protobuf模式将消息发布到使用python的Pulsar客户机包的Apache主题？
根据文档，它只支持Avro、String、Json和字节。有工作要做吗？
浏览 10提问于2022-01-12得票数 2
回答已采纳
2回答
我有一个带有一堆依赖项的maven项目，其中一个我想打印一行到控制台，名为pulsar-log4j2-appender。我尝试在Intellij中打开有问题的.class文件： External Libraries | Maven: org.apache.pulsar:pulsar-log4j2-appender:2.6.0 | pulsar-log4j2-appender-2.6.0.jar | org.apache.pulsar.log4j2.appender | PulsarManager.class 当我尝试添加System.out.println语句时，Intellij显示该文件是
浏览 107提问于2020-07-24得票数 0
回答已采纳
在k8s中使用apache pulsar时，是否可以在一个应用程序中创建多个pulsar客户端并同时连接到pulsar？我知道惯例是使用单个pulsar客户端，但我很好奇是否可以使用多个客户端。这不会导致任何错误吗？
浏览 19提问于2021-03-26得票数 1
我使用Apache Pulsar Python客户端来连接我的微服务。我想创建Key_Shared消费者，如下所示：
import pulsar,_pulsar
client = pulsar.Client('pulsar://localhost:6650')
consumer = client.subscribe('my-topic', 'consume-id',
consumer_type=_pulsar.ConsumerType.KeyShared)
但我得到了以下错误：
Attr
浏览 13提问于2020-06-05得票数 1
我在Docker容器中以standalone模式运行Apache pulsar。
我正在将日志文件行发布到pulsar主题。总日志大小约60G。
脉冲星容器不断耗尽/磁盘上的磁盘空间，必须终止。
这是默认配置。docker-compose文件如下所示
pulsar:
image: apachepulsar/pulsar
container_name: pulsar
command: bin/pulsar standalone
ports:
- 6650:6650
- 8080:8080
有没有办法限制脉冲星磁盘的使用，这样它就
浏览 3提问于2020-06-18得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
