+1 We can imitate the PulsarClient object, and in the BaseContext interface, add PulsarAdmin and PulsarAdminBuilder as interfaces at the same time.
-- Thanks Xiaolong Ran Neng Lu <nl...@apache.org> 于2023年1月19日周四 02:28写道： > 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 > > >
