Hi Harsha,
Thank you for the quick response. Please find the full context below.
We have implemented/customized security feature on top of Kafka 0.8.2
version. Now, all the consumers should be able to pass those security
configs.
I have reviewed the storm code but i have few questions here.
*My
Rajashekar, Current storm kafka connector uses kafka's
simpleconsumer api. Only kafka's new consumer api has the security
enabled. There is work being done to port kafka connector to use new
consumer api.
Thanks, Harsha
On Thu, Jan 28, 2016, at 02:04 PM, Rajasekhar wrote:
>
> Hi,
Hi,
*Backgroud* :
I am working on kafka-Storm project. Storm reads messages from secured
kafka cluster.
SSL security was implemented in Kafka broker. Consumers (In our case it is
Storm) has to provide the necessary information to get secured connection
to kafka broker.
Client has to provide below
