Since you have the Kafka configuration, you can open your own connection to ZK. You also have the advertised listeners from same file, if you want to connect back to the Kafka cluster to check things. I'd use that if possible for your use-case, accessing the log files directly seems a bit risky to me.
I'd love to hear what your authentication workflow looks like where you need to actually read data from disk. On Fri, Mar 8, 2019 at 1:20 PM Christopher Vollick <christopher.voll...@shopify.com.invalid> wrote: > Hello! I'm experimenting with an implementation of > AuthenticateCallbackHandler in an external JAR I’m loading, and I'd like to > use some of the methods / properties from ReplicaManager (or KafkaServer > which has a ReplicaManager), but I don't see anything that's passed to me > or any singletons that will give me access to those objects from my class. > > I figure that’s probably intentional, but I wanted to ask just incase I’m > missing a hook I don’t know is there. > Specifically, I was looking to either get access to the logs on disk > (ReplicaManager’s fetchMessages method) so I could read some things, or > alternatively the ZooKeeper connection. > > Since I’m in a JAR, any solution which involves changing the core Kafka > code-base isn’t something I’m interested in. > Thanks! -- *Gwen Shapira* Product Manager | Confluent 650.450.2760 | @gwenshap Follow us: Twitter <https://twitter.com/ConfluentInc> | blog <http://www.confluent.io/blog>
