hi team! i am trying to use Apache Kafka Connector...
# troubleshooting
t
hi team! i am trying to use Apache Kafka Connector to reading data from kafka, i did as said in the doc but i am keep getting this problem
No LoginModule found for org.apache.kafka.common.security.scram.ScramLoginModule
can some one please help me on this.
m
πŸ‘€ 1
We shade the Flink Kafka connector, so your
org.apache.kafka
value should be updated to point to the shaded one
πŸ‘€ 1
t
thank u Martijn! its looks like that is the cause of the problem,
now i am getting SSL handshake failed due to No name matching hostname found
any way i am getting closer to the solution πŸ˜‚
πŸ˜€ 1
m
One step at a time πŸ˜‰
t
solved the problem πŸ™ŒπŸ» by adding
setProperty(SslConfigs.SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG, "")
to the KafkaSourceπŸ₯²gratitude thank you