The proposal makes sense to me. The only note I want to add is to make sure the PulsarAdmin access in Source and Sink is also controlled by the flag `exposePulsarAdminClientEnabled`. Similar to the following:
https://github.com/apache/pulsar/blob/master/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntimeFactory.java#L111 On 2023/01/03 14:31:52 Alexander Preuss wrote: > Hi all, > > I opened a PIP to discuss making PulsarAdmin accessible in Pulsar IO > connectors through SinkContext and SourceContext: > https://github.com/apache/pulsar/issues/19123 > > Looking forward to hearing your thoughts, > Alex >
