I’ve deployed Kafka on Kubernetes on GCP, referring the below link :
https://www.qwiklabs.com/focuses/11777?locale=zh_TW&parent=catalog
I’ve created Ingress port, and am able to access the Control Center on the kafka-ingress port.
However, when i try to access the kafka broker using external endpoint(kafka-bootstrap-lb) it gives the following error :
104.198.74.49:9092/bootstrap: Disconnected: verify that security.protocol is correctly configured, broker might require SASL authentication (after 380ms in state UP)
Do I need to access the broker using SASL ? Any input on this would be appreciated!
tia!
hi,
quickly checked the blog post and github repo.
if my understanding is correct there is a sasl config in place, see
hth,
michael
HI -
Thanks for the response !
I’m trying tp understand how to access the broker using the sasl config you mentioned to access the brokers in the K38 cluster.
In the local instance of my kafka cluster, i run the following command -
$CONFLUENT_HOME/bin/kafka-console-producer --broker-list Karans-MacBook-Pro.local:9093 --topic karantest --producer.config $CONFLUENT_HOME/props/client-ssl.properties
What do i need to do when i want to access the kafka cluster in Kubernetes(in GCP) ?
any pointers on this will really help!
tia!
Pls note - this is another pod (client-console) in the k38 cluster which is able to access the kafka broker and produce/consume data using the command →
kafka-console-consumer --bootstrap-server kafka:9071 --consumer.config /etc/kafka-client-properties/kafka-client.properties --topic clicks --from-beginning
However, i’m trying to figure out how to access from my local machine (or any other external client)
Pls let me know if you have any inputs on this.
thanks!
thx
basically it should work similar as connecting from within the k8s cluster
copy the client-properties to your local env and then
104.198.74.49:9092 --consumer.config /etc/kafka-client-properties/kafka-client.properties --topic clicks --from-beginning```