Re: Using Kafka Internals from Within Plugin

2019-03-11 Thread Christopher Vollick
Yeah, I agree. I looked at CruiseControl and it seems to be using the same kind of model (as a producer). The auth model we’re planning has a set of apps which each self-sign a token, so we need a list of keys and identities we trust, which changes over time. Kinda sounds like a log ;), so our

Re: Using Kafka Internals from Within Plugin

2019-03-08 Thread Gwen Shapira
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