Producer and Consumer for external access of kafka service about kubernetes-kafka HOT 6 OPEN

You won't get outside zookeeper access. Do administration from inside, and use the new kind of bootstrapping for outside clients.

from kubernetes-kafka.

"Do administration from inside" . Pardon ! But I didn't get you. Can you please be a little more informative.
Much appreciated :)

from kubernetes-kafka.

With new kafka versions you basically only need zookeeper access for topic maintenance etc. For everything else use "bootstrap servers", which works using the Outside services.

from kubernetes-kafka.

" --override advertised.listeners="INTERNAL_PLAINTEXT://${HOSTNAME}.broker.kafka.svc.cluster.local:9092,EXTERNAL_PLAINTEXT://$(eval wget -t3 -T2 -qO- http://169.254.169.254/latest/meta-data/public-hostname):9093" "
I have been asking a lot of questions .
But, What is this External Plaintext referring to ?
And could you help me with the command for kafka-producer ?

from kubernetes-kafka.

@ranjanshubham, if it helps, I applied to zookeeper the same logic applied to the brokers, i.e. I added a NodePort service as in /outside-services/outside-xxx.yml and changed the zookeeper/10zookeeper-config.yml accordingly so that labels were applied to the zk pods in order for the service selector to apply.

I couldn't tell you how orthodox or otherwise this approach is but I currently use zookeeper to retrieve the bootstrap broker list for my external clients so I need the service exposed.

from kubernetes-kafka.

I think this is too generic for this repo. It's a general Kafka question and I can only refer to for example the Kafka Definitive Guide book.

from kubernetes-kafka.