надо пересобрать из событий. В Кафке приходится болезненно вычитывать всю партицию, просто пропуская сообщения для "дргого" ключа. в Пульсаре это можно сделать как-то "фильтром по ключу"?
в 2.4 они добавили key_shared: http://pulsar.apache.org/docs/en/concepts-messaging/#key_shared позволяет слушать по ключу, а не по partition-у. Не уверен правда что позволит отфильтровать на сервере
Обсуждают сегодня