Camel Kafka doesn't support SASL_PLAINTEXT security protocol
Issue
I have enabled SASL in Kafka server and I try to configure my consumer endpoint like :
<route id="KafkaConsumerRoute">
<from uri="kafka:localhost:9092?topic=test&groupId=testgroup&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&valueDeserializer=org.apache.kafka.common.serialization.StringDeserializer&securityProtocol=SASL_PLAINTEXT"/>
<log message="The message contains ${body}"/>
<to uri="mock:result"/>
</route>
We would need this for our application to authenticate the consumers based on username and password.
Environment
- Red Hat JBoss Fuse
- 6.3.0
Subscriber exclusive content
A Red Hat subscription provides unlimited access to our knowledgebase, tools, and much more.