-
Hi! I need some help with authorization which works with WaterDrop but not with Ruby-Kafka. I have been given username, password and broker urls. With WaterDrop I can login and produce messages to topic when I have set username, password and these two parameters: I cannot find a way to define those (or similar) parameters in Ruby-Kafka and I'm getting "Connection error EOFError" during handshake. Sasl_scram_mechanism parameter in this library has possible values sha512 and sha256 and neither work for me. Sasl_over_ssl is set as false. Am I trying to login to Kafka incorrectly, or could there be a way to get Ruby-Kafka to behave the same way as WaterDrop when sasl mechanism is plain? Thanks! |
Beta Was this translation helpful? Give feedback.
Replies: 1 comment
-
Problem solved. I now have these parameters for constructor and login works: kafka = Kafka.new(
[brokers],
sasl_plain_username: "x",
sasl_plain_password: "y",
sasl_over_ssl: true,
ssl_ca_certs_from_system: true
) I was missing parameter -Veli-Pekka |
Beta Was this translation helpful? Give feedback.
Problem solved.
I now have these parameters for constructor and login works:
I was missing parameter
ssl_ca_certs_from_system
andsasl_over_ssl
was incorrectly set as false.-Veli-Pekka