pulsar

就是这个failed messages会显示很多条

昨天bookie oom挂掉之后，现在启动就报这个错

function download目录，下载function jar，为什么同一个应用的每个实例id都要下载一个同样的jar？同一个节点上下载一个不就行了吗？这是基于什么考虑的？如果我一个胖包是200MB，一个节点启动10个并发，光这个应用的jar就要复制10份出来了。。。<@U6E5YMRKR>

<@U6E5YMRKR> hi  看到上面您说的 pulsar的同步send是等ack回来的，但是我在本地测试发现并没有阻塞
```producer.send(gson.toJson(xxx).getBytes(StandardCharsets.UTF_8));
producer.send(gson.toJson(xxx).getBytes(StandardCharsets.UTF_8));
producer.send(gson.toJson(xxx).getBytes(StandardCharsets.UTF_8));
producer.send(gson.toJson(xxx).getBytes(StandardCharsets.UTF_8));```
producer是这样send的，function这边是
```context.getCurrentRecord().fail()```
然后发现四条消息还是全部都收到了

请问一下，我发布了多个function，运行稳定之后，经常会看到assignments这个topic有多个backlog没有消费，这个不太明白原因

function正常在运行，但functions-worker的日志一直抛心跳异常

<https://github.com/apache/pulsar/issues/8022>
我刚又测试了kafka的io，使用--source-config-file选项指定yaml配置，确实报解析不了的错误呀

你可以搜索该应用添加下，Pulsar PMC 来审批通过。我试了下，目前 Pulsar Slack 使用的是免费版本，目前允许安装的 App 数量已满。。。

:alarm_clock:️ Hi, Pulsar Summit Asia 2021 - 亚洲峰会 2021 演讲征集*倒计时*！
:link:️ 欢迎提交议题咯 - <https://sessionize.com/pulsar-summit-asia-2021/>
:eyeglasses:️ 维度可以是案例、运维、技术探究、Pulsar 与其他系统联合解决方案等等都可以

pulsar的大佬能帮解答一下吗，目前我们测试环境出现了一个问题，
pulsar：2.9.2
Python client: 2.9.2
多个consumers用的shard模式，一开始还正常消费，跑一会儿就有些consumer不消费了，查了一下issue有点像#10390这种的情况，看看要从哪些点上排查一下麻烦告知一下，多谢了