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 p
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
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
