Archives of Support Questions (Read Only)

This is an archived board for historical reference. Information and links may no longer be available or relevant
Announcements
This board is archived and read-only for historical reference. To ask a new question, please post a new topic on the appropriate active board.

flume kafka sink for SASL_SSL protocol is not working

avatar
New Member

I have been trying to enable SASL_SSL protocol for kafka sink and getting error . I attached my flume conf and flume log file here. Could anyone please tell me whats the reason?stacktrace.txtkafka-sasl-ssl-sink.txt

1 ACCEPTED SOLUTION

avatar
Rising Star

@Mehedi Hasan SASL_SSL is not available in the older kafka consumer api. The new kafka consumer api integration is in Flume v.1.7.0 as noted here: https://issues.apache.org/jira/browse/FLUME-2821. What is the version of Flume you are using?

View solution in original post

2 REPLIES 2

avatar
Rising Star

@Mehedi Hasan SASL_SSL is not available in the older kafka consumer api. The new kafka consumer api integration is in Flume v.1.7.0 as noted here: https://issues.apache.org/jira/browse/FLUME-2821. What is the version of Flume you are using?

avatar
New Member

@Shashank Chandhok

i am using the one which is shipped with HDP 2.6 that is flume 1.52. with added feature of 1.6