I'm saying it after a lot of try: It's still the easist way to spin up a healthy kafka server in 2023!
@worldwide6626 Жыл бұрын
Is plaintext enough?
@rsantamaria23092 жыл бұрын
Thanks for all those explanations. You are excellent. And I like when you talk about « Listeners » that is also the way I prononce it in my head when I am writing. Thanks again.
@erwinrommel55933 жыл бұрын
How do you configure the topic inside your kafka could you show that
@thedrunkencatlady4 жыл бұрын
Thank you so much for the simple tutorial!! ☺☺
@hnasr4 жыл бұрын
🙏🙏
@meliscolak13033 жыл бұрын
thank you so much!
@seriouslycurious4 жыл бұрын
My Kafka instance is unable to connect with zookeeper. tried machine name as well as localhost. Any other options ? Here is the error - [main-SendThread(localhost:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) [main-SendThread(localhost:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket error occurred: localhost/127.0.0.1:2181: Connection refused
@seriouslycurious4 жыл бұрын
adding --net host resolved the issue, was able to pass the IP from zookeeper's startup log
@WMay1164 жыл бұрын
@@seriouslycurious I am having the same issue. can you post your full docker command please?
@divyanshagarwal9934 жыл бұрын
I used the following commands: 1. For running zookeeper: docker run --net host --name zookeeper -p 2181:2181 zookeeper 2. For running kafka broker: docker run --net host --name kafka -p 9092:9092 -e KAFKA_ZOOKEEPER_CONNECT=localhost:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092 -e KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1 confluentinc/cp-kafka I don't get any errors when running the 2 containers and I used brokers: ['localhost:9092'] in my code. But still it doesn't work. It shows an error: "ERR refused connection to broker" something like that Can someone help?
@lillllliiill-r3e4 жыл бұрын
@@divyanshagarwal993 change KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092 to. KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://YOUR_IP_ADDRESS:9092 because localhost refers to your host machine but since you are using docker, now it means localhost refers to your kafka container. Change localhost to your host machine's IP
@leniedor7332 жыл бұрын
@@lillllliiill-r3e Nasty solution but works,it happened a few years to me xD An alternative for your ip (which is equivalent at your network context) --network="host"
@onhazrat Жыл бұрын
🎯 Key Takeaways for quick navigation: 00:01 🐘 To set up Zookeeper and Kafka in Docker, ensure you have Docker installed. 00:30 🚀 Use `docker run` to spin up a Zookeeper instance, provide a container name, and expose port 2181. 01:10 📡 For Kafka, expose port 9092, set environment variables for Zookeeper connection, and advertised listener. 03:25 💡 Kafka broker requires environment variables for Zookeeper connection and advertised listener. 07:48 🔄 Configure Kafka replication factor if running a single broker to avoid confusion. Made with HARPA AI
@abusufiyanathani2393 Жыл бұрын
I am getting an error saying zookeeper audit is disabled, can anyone help me..
@weitanglau1623 жыл бұрын
Great video! Can you also make a video on deployment on kubernetes as well?
@PiyushKumar-od6ei3 жыл бұрын
Can one video happen using Docker Swarm?
@tSobota4 жыл бұрын
Hi Hussein, thanks for your video :) How about one RPC stack video? Thrift or gRPC. How the hell it works internally? :D
@hnasr4 жыл бұрын
Love it! gRPC is one of the most requested videos in the channel. Its coming
@rahulkumarsingh17164 жыл бұрын
I am getting an error while connecting kafka to zookeeper, it says connection refused.. What to do?
@The-Cat4 жыл бұрын
me too it's frustrating.... have you found the solution after 4 months ?
@jannielouwrens12104 жыл бұрын
@@The-Cat Try starting both the zookeeper and the kafka containers with the --net=host switch, e.g. docker run --name zookeeper -p 2181:2181 --net=host zookeeper
@faisalaleissa20123 жыл бұрын
. Will not attempt to authenticate using SASL (unknown error)
@oluwaseyisoremekun57293 жыл бұрын
Add -net=host to the docker command that runs kafka