Re: Using Kafka Internals from Within Plugin

2019-03-11 Thread Christopher Vollick
ectly 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 > wrote: > >> Hello! I'm experimenting with an implementa

Using Kafka Internals from Within Plugin

2019-03-08 Thread Christopher Vollick
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

Semi Proposal: Unclean Leadership Elections and Out of Sync Brokers

2018-09-18 Thread Christopher Vollick
Hey! I’m seeing behaviour I didn’t expect, and I’d like some expert opinions on it. (TL;DR min.insync.replicas=2 and acks=all isn’t enough to tolerate losing a leader transparently and safely, but maybe it could be) Lets say we have a topic with one partition, replication factor 3. Leader 0, Fo