All Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
  • shuai ifly_liukan 23
    •
    Pulsar Namspace 级别的集群隔离命令使用失效问题
    背景 近期在使用 pulsar-admin ns-ioslation-policy 命令的时候，发现指定 primary 圈定 broker-regex-list 列表，发现无法使用正则匹配出 Port，必须要指定 ip:* 才能生效。 请问是否在 2.8.0 版本的时候，pulsar-admin 不支持到 broker 的端口级别隔离吗？ 想使用端口级别隔离的原因： 例如使用一台机器，在上面堆叠部署 broker 服务，例如 8080,8081,8082 的三个节点，这样指...
    broker-level-isolation pulsar-v2.8.2
    2 votes
    2 answers
    400 views
  • shuai Janle 11
    •
    Pulsar 2.9.2 使用延时队列偶尔丢失消息的问题
    所使用版本:2.9.2版本, 部署环境:k8s部署 业务场景: 延时消息每30s发送一条车辆拉取位置消息，收到上一个消息再发送一条30s延时消息出去。 消息配置 使用的分区消息,消费者使用Shared模式. {code...} 结果: 消息每次都会发送成功并且返回msgid，但是消费者有时候偶尔就会收不到消息。导致发送的消息丢失. 这种情况遇到过么？应该怎么解决？
    iov delayed-message pulsar-v2.9.2
    1 votes
    2 answers
    274 views
  • shuai David 18
    •
    Pulsar集群中Bookie节点下线如何保证数据不丢失?
    Pulsar中,数据是按照数据段(segment)来存储的, 对应在Bookie节点上为ledger. 假设场景: Bookie1: ledger1, ledger2 Bookie2: ledger3, ledger4 如果Bookie1节点down掉了, ledger1/ledger2的数据是否就丢失了??
    support
    0 votes
    1 answers
    333 views
  • shuai ifly_liukan 23
    •
    Pulsar GEO 关闭复制策略再开启后数据同步是延续还是重开
    场景： 设 A、B 两地分别有集群 A 和 B，有租户 ifly，namespace 为 uup。Namespace 层面配置了 A 和 B 双向复制。 此时 A 有 topic persistent://ifly/uup/sync 复制积压（replication_backlog）1000000 条数据。此时取消 uup 这个 Namespace 级别的 A/B 两地的消息复制。 {code...} 请问： 此时 A 地的 1000000 条消息积压会不会被清理掉？ 考虑配...
    pulsar-v2.8.2 geo-replication
    0 votes
    1 answers
    301 views
  • shuai Lambert Jiao 3
    •
    消费topic数据时偶现消费端不消费数据问题【开启限流】
    pulsar版本: 3.3.0 问题描述: 开启限流下，消费topic数据时偶现消费端不消费数据问题，消费组对应的msgBacklog和backlogSize都大于0，重启broker或者重新创建订阅组时才会消费到数据； 相关设置: namespace设置了以下策略： pulsar-admin namespaces set-message-ttl -ttl 3d paas-msg-sub/xxxxxxx pulsar-admin namespaces set-retentio...
    pulsar-v3.3.0
    0 votes
    1 answers
    223 views
  • shuai ifly_liukan 23
    •
    Pulsar集群中的存储集群Bookkeeper集群，如何才能做到优雅下线bookie节点
    问题： 当前在生产环境的Pulsar集群中，准备下线一台Bookie存储节点，将Bookie的配置文件中的配置forceReadOnlyBookie进行设置，改为true。重启bookie节点将其设置为只读模式。但是发现，待无写入流量的时候，将Bookie节点进行停止。其他的Bookie节点大批量的报错，提示报错如下： 当前使用Pulsar的版本是2.8.0。 麻烦社区大佬看看是不是还有什么地址没有考虑到，导致下线Bookie节点的时候，其他节点还在跟改下线的Bookie节点...
    pulsar-v2.8.0
    0 votes
    1 answers
    210 views
  • shuai zhengcongyi 1
    •
    采用kop插件消费pulsar慢问题
    ck只支持kafka协议，运行一段时间就变慢， ck日志会一直打印 StorageKafka (): Can't get assignment. Will keep trying，消费就很慢，一直在尝试消费 版本： pulsar:3.0.6 kop:3.0.6 {code...}
    emergency
    0 votes
    3 answers
    195 views
  • shuai ifly_liukan 23
    •
    pulsar的背压机制
    场景： 北京上海广州三地进行消息的相互同步，发现夜间流量高峰期间，城际网络专线有延迟情况，会影响到本地的replication_backlog积压，但为什么本地生产的消息本地进行消费也会受到专线拥塞的影响，造成本地消费消息积压。 请问pulsar在geo这一块是不是有设置背压机制，这块的原理，期望专家可以解答一下。
    tag-required
    0 votes
    0 answers
    183 views
  • shuai David 18
    •
    Pulsar发送Json Schema数据, 消费端丢失字段
    问题描述 Producer发送JSON类型数据到Pular集群, Consumer在消费拿到数据时, 存在字段丢失现象. 具体类定义: 自定义三个类MessageBody, User, Student. MessageBody作为Schema.Type, User是MessageBody其中一个字段, Student是User的子类. 构建MessageBody时, User字段赋值为一个Student实例. 最终消息收到后, 反序列化回来, Student中的字段丢失了 {...
    tag-required
    0 votes
    1 answers
    140 views
  • shuai pharsalia 1
    •
    Pulsar是否有配置能优化Bookkeeper集群decommissionbookie的速度
    我们一个Pulsar集群有3个节点，现在需要升级Pulsar所在的虚拟机节点，升级流程是： 对于每个节点，按顺序进行退役节点，重建虚拟机，重新加入pulsar集群。 现在生产环境退役节点时，每个节点大概有2000-4000个ledgers需要复制，耗时1-3小时+，时间太长超过了维护窗口时间。 请问有配置能优化退役节点的速度吗？ Pulsar版本是2.8.1
    tag-required
    0 votes
    0 answers
    68 views
    • Hot Questions