Re: Kafka 0.9 API connection refused exception not raised to client code

Hmm, as a newbie with Kafka v0.9 and having tested this scenario, this is what is happening: You can reproduce failure by setting just BOOTSTRAP_SERVERS_CONFIG, by not passsing custom timeouts, it should then invoke your callback in producer.send(record, new ProducerCallback(record)); with "org.ap

Chaining custom processors with DSL

Hello, Using the low level API its possible to chain processors like this builder.addSource("Source", ...); builder.addProcessor("Process1", new MyProcessorSupplier(), "Source"); builder.addProcessor("Process2", new MyProcessorSupplier2(), "Process1"); Can I do something similar with DSL?

cnxn.saslServer is null: cnxn object did not initialize its saslServer properly.This might be an issue on krb5.conf

Hi fellows, I’ve got an issue on KAFKA Kerberos configures. Could any of you can help me out of this. I will appreciate that. Red Hat 4.4.6-4 Zookeeper error log when I was starting KAFKA server. krb5.conf [logging] default = FILE:/var/log/krb5libs.log kdc = FILE:/var/log/k

Re: TLS based ACL: Does Kafka support multiple CA Certs on broker

Did you make sure both those CA's are imported into Broker's truststore? -Harsha On Fri, Jul 15, 2016 at 5:12 PM Raghavan, Gopal wrote: > Hi, > > Can Kakfa support multiple CA certs on broker. > If yes, can you please point me to an example. > > Producer signed with second CA (CA2) is failing.