2020-07-16 16:03:27 UTC - Chris: I'm working on implementing a form of
broker-side filtering of messages and could use a bit of help with pulsar
internals. I've got basic filtering via byte pattern and regex working, but am
stuck on decoding messages with schema inside the broker. I can get to both the
schema registry service and schema storage, but it isn't documented what schema
ids are, and it's not the topic name as far as I can tell. Any pointers on this?
tada : Julius S
----
2020-07-16 21:38:38 UTC - Chris:
```cnx.getBrokerService().getPulsar().getSchemaRegistryService()
.getSchema("my-property/my-ns/my-topic1").get()```
Kinda figured it out, but it's not pretty. The key is topicName without the
protocol. Anyone know what the function is to strip `persistent://` from a
topic name? I've got a hardcoded substr since I only use persistent topics
:laughing:
----
