腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Apache
Pulsar
支持
的
最大
消息
大小
stream
、
message-queue
、
apache-pulsar
Apache
Pulsar
支持
的
最大
消息
大小
是多少? 我试着阅读文档。但我找不到任何相关信息。
浏览 88
提问于2020-04-27
得票数 4
回答已采纳
2
回答
Apache
Pulsar
vs Kafka -消费者是否会拉出(投票)
消息
?
apache-kafka
、
kafka-consumer-api
、
apache-pulsar
我知道在Kafka中,消费者从代理主题中拉出
消息
(拉出)?谢谢
浏览 2
提问于2020-04-10
得票数 4
1
回答
是否有任何方法通过websocket-/REST将
Pulsar
与模式注册中心一起使用?
apache-pulsar
我有一个Java客户端客户端正在接收
Pulsar
(v2.10.0) AVRO
消息
(雇员),如下所示:import现在,我试图通过Websocket 或REST 生成
消息
时获得相同
的
结果。该
消息
被使用者接受和接收,但抛出一个异常: 线程"main“org.
apache
.
pulsar
.shade.com.google.common.
浏览 2
提问于2022-05-31
得票数 2
1
回答
线程"main“java.lang.NoClassDefFoundError异常: org/
apache
/
pulsar
/client/api/PulsarClient
java
、
apache-pulsar
我试图通过java执行
apache
pulsar
生产者和消费者程序,我在GCP虚拟机上安装了
apache
-
pulsar
standalone,并在独立模式下启动了集群。,这是显而易见
的
,因为
pulsar
没有安装在windows机器上。; import org.
apache
.
pulsar
.client.api.
浏览 344
提问于2019-02-10
得票数 1
1
回答
如何在脉冲星客户端包中使用protobuf模式
消息
?
python
、
apache-pulsar
、
python-pulsar
是否有一种方法可以使用Protobuf模式将
消息
发布到使用python
的
Pulsar
客户机包
的
Apache
主题? 根据文档,它只
支持
Avro、String、Json和字节。有工作要做吗?
浏览 10
提问于2022-01-12
得票数 2
回答已采纳
4
回答
与
Apache
Pulsar
相比,Kafka
的
优点和缺点是什么
apache-kafka
、
apache-pulsar
雅虎开发了
Pulsar
,pub-sub
消息
系统,并使其开源。它现在是
Apache
的
孵化项目。因为Kafka也用于相同
的
目的。想知道,卡夫卡相对于脉冲星
的
主要正负点。
浏览 1
提问于2017-09-05
得票数 56
1
回答
如何使用脉冲星作为Log4j2
的
附件?
java
、
log4j2
、
apache-pulsar
我正在尝试将
Apache
设置为log4j2
的
一个附录。这里没有太多
的
文档,但是我在这里找到了一些例子。我已经建立了一个玩具示例,在这个示例中,生产者正在记录单个
消息
,并且在
Pulsar
服务器上订阅了同一个主题并侦听
消息
。消费者收到了一些东西,但没有收到我所期望
的
信息:Message received: 18:05:27.510 [
pulsar
-client-io-; import org.<em
浏览 5
提问于2020-06-24
得票数 3
回答已采纳
1
回答
PulsarClient.builder()超长错误记录器
java
、
log4j
、
slf4j
、
apache-pulsar
、
pulsar
我认为这是因为我
的
PropertyConfigurator制作不好,但是即使我使用defaultConfigurator,也会得到同样长
的
错误.当我试图让我
的
PulsarClient变成这样
的
时候,它就坏了(Native.java:247) at org.
apache
.
pulsar
.client.
浏览 18
提问于2022-09-24
得票数 0
回答已采纳
3
回答
Apache
消息
传递语义
queue
、
message-queue
、
apache-pulsar
我研究了
Apache
文档中
的
消息
传递语义。
Apache
函数所提到
的
传递语义(至少一次、最多一次和有效一次),如果我们不使用
Apache
函数,那么有哪些不同
的
交付语义可用呢?
浏览 8
提问于2020-04-30
得票数 3
回答已采纳
1
回答
Docker构建如何将库添加到golang构建
docker
、
go
、
dockerfile
、
apache-pulsar
我正在构建一个处理
Apache
Pulsar
的
GO应用程序。Go客户端需要C++库,正如
Pulsar
文档所要求
的
( Kafka btw也是如此)。 我想把所有这些都打包到一个容器中,尽可能小。我通常使用SCRATCH并从另一个基于golang
的
容器复制输出。/app"] 使用此命令会使构建失败,从而查找缺少
的
符号 /go/pkg/mod/github.com/
apache
/
浏览 16
提问于2020-01-18
得票数 4
1
回答
Apache
Pulsar
连接被拒绝
apache-pulsar
在我
的
Pulsar
消费者/生产者中,当我试图连接到
Pulsar
时,我会收到以下错误
消息
: org.
apache
.
pulsar
.client.api.PulsarClientException: java.util.concurrent.CompletionException: java.util.concurrent.CompletionException: org.
apache
.
pulsar
.shade.io.netty.channel.A
浏览 1
提问于2020-06-11
得票数 0
2
回答
是否可以在整个项目中强制使用特定
的
库版本?
gradle
、
dependencies
、
snyk
我试图修复Snyk工具在我
的
程序中发现
的
一些漏洞,但其中一些漏洞来自我正在使用
的
库(比如
Apache
的
Pulsar
)。例如,
Pulsar
正在使用gson
的
2.8.6版本,根据Snyk
的
说法,gson很容易受到攻击,下一个安全版本是2.8.9。是否有可能强制使用2.8.9版本
的
gson (通过gradle)使用我所使用
的
所有库?更确切地说,不是因为这是一个很愚蠢
的
想法,容易出现意想不
浏览 5
提问于2022-01-05
得票数 2
1
回答
按租户/主题使用
Apache
Pulsar
进行端到端加密
encryption
、
multi-tenant
、
apache-pulsar
我正在尝试使用
Apache
Pulsar
进行端到端加密。到目前为止,我看到
的
示例看起来类似于http://
pulsar
.
apache
.org/docs/en/security-encryption/ 我在密钥轮换部分看到每4小时获取一次加密密钥(公钥/私钥)这似乎表明您只能使用单个密钥来加密您发送
的
消息
。 我希望能够对不同
的
主题/租户使用不同
的
加密密钥。<
浏览 24
提问于2020-07-15
得票数 0
1
回答
unacked_messages_timeout_ms
的
Pulsar
客户端等价物(py- GoClient )
python
、
go
、
apache-pulsar
、
python-pulsar
在
Pulsar
Python客户端中,有订阅者选项unacked_messages_timeout_ms来设置未确认
消息
重新发送
的
时间间隔。 与
Pulsar
Go客户端相当
的
是什么?) 戈朗 go_consumer, err := client.Subscribe( Topic: "my-topic",SubscriptionName: "go-subscriber", Typ
浏览 43
提问于2021-08-31
得票数 0
回答已采纳
2
回答
如何查询
Apache
-
Pulsar
?
apache-pulsar
Apache
pulsar
通过分层存储减载器提供了一个非常有趣
的
架构。 我想知道如何从另一个应用程序进行交互式查询?我
的
意思是直接查询键值系统/“数据库”,而不是使用
pulsar
-sql,后者在底层使用Presto。 在@sijieg中,在twitter上,has posted以下模式: ? 看起来我可以访问State-store (甚至是Segment-reader)并直接访问博彩公司中
的
数据(根据Metastore ?)我们如何访问这些状态存储/段阅读器并访问数
浏览 17
提问于2020-04-07
得票数 2
1
回答
容器中
的
Apache
Pulsar
磁盘使用情况
diskspace
、
apache-pulsar
、
pulsar
我在Docker容器中以standalone模式运行
Apache
pulsar
。脉冲星容器不断耗尽/磁盘上
的
磁盘空间,必须终止。docker-compose文件如下所示 image: apachepulsar/
pulsar
command:bin/
pulsar<
浏览 3
提问于2020-06-18
得票数 1
1
回答
Apache
Pulsar
异步消费者设置(可完成
的
未来)
java
、
completable-future
、
apache-pulsar
我正在尝试为
Apache
Pulsar
设置一个异步消费者,但我
的
问题是只收到一条
消息
,除非我重新启动Spring Boot应用程序,否则没有其他
消息
。不幸
的
是,关于在脉冲星上使用CompletableFuture
的
文档不是很好,我还是个新手。收到
消息
,就应该随后调用receiveAsync(),否则它会在应用程序中造成接收请求
的
积压。”Docs:
Pulsar
Docs:https://
p
浏览 111
提问于2021-04-20
得票数 1
回答已采纳
2
回答
用于
Apache
与miniO Lake (java.lang.IllegalArgumentException)
的
德尔塔湖水槽连接器
java
、
docker
、
delta-lake
、
apache-pulsar
我正在尝试运行新
的
apache
脉冲星Lakehouse Sink Connector,并获得java.lang.IllegalArgumentException。 下面是我
的
设置。,并将NAR包复制到容器中
的
Pulsar
连接器目录$
PULSAR
_HOME/connectors。我使用了类似于所描述
的
的
配置,并将tablePath值与我
的
miniO路径重新放置在一起。我将文件命名为sink-connector-config.j
浏览 19
提问于2022-09-20
得票数 1
回答已采纳
1
回答
PulsarClientException:已关闭
的
连接网络、防火墙、
Pulsar
令牌和角色是正确
的
。
java
、
spring
、
apache-pulsar
我正在为
Apache
使用Java用户,而我
的
应用程序不会启动。脉冲星令牌是正确
的
。我们可以使用telnet和curl命令命中目标SSL端口(6651),所以它不是防火墙或网络问题角色在
Pulsar
中有足够
的
权限,我们正在为正确
的
Pulsar
集群命中正确
的
端点,我们在这个环境中使用正确
的
信任证书‘使用者’
的
错误;嵌套异常是org.springframework.beans.BeanInstan
浏览 1
提问于2021-07-27
得票数 0
1
回答
Apache
Pulsar
-根据时间戳,Consumer.seek()方法
的
行为是什么?
java
、
apache-pulsar
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),
浏览 83
提问于2020-10-26
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Apache Pulsar的多租户消息系统
Apache Pulsar 2.1.0 发布,雅虎的分布式消息发布平台
消息队列上云挑战与方案:腾讯云的 Apache Pulsar 实践
腾讯超大 Apache Pulsar 集群的客户端性能调优实践
官宣:Apache Flink 1.14.0 发布
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券