==Command line producer==Az összes példa során a '''test2-topic''' nevű topic-ot fogjuk használni. A topic-ok kezeléséhez a Kafka csomagban a bin mappába találunk adminisztrációs scripteket. Töltsük le a Kafka-t vagy a kafak.apache.org-ról (https://kafka.apache.org/downloads) vagy a confluent oldaláról (https://www.confluent.io/download/), amiben jóval több script-et találunk mint az apache-os változatban. Új topic-ot a '''kafka-topics''' paranccsal készíthetünk. Paraméterként meg kell adni a zookeeper szerver elérhetőségét, mivel a Kafka a konfigurációt a zookeeper-ben tárolja, így az új topic-ot a zookeeper-be kell beírni. A zookeeper-t publikáltuk az ingress hálózatra, így bármelyik node IP címével és a publikált porttal (32181) elérhetjük a szervert. Kérjük le a worker0 node IP címét. Ezen keresztül fogjuk elérni a zookeeper-t: <pre># docker-machine ip worker0192.168.42.113</pre>
És most hozzuk létre a '''test2-topic''' nevű topic-ot.
<pre>
$ ./kafka-topics --create --zookeeper 192.168.42.113:32181 --replication-factor 1 --partitions 1 --topic test2-topic
</pre>
A --list kapcsolóval listázhatjuk a Kafka cluster-ben elérhető topic-okat, amit a parancs szintén a zookeeper cluster-ből olvas ki.
<pre>
$ ./kafka-topics --list --zookeeper 192.168.42.113:32181
__confluent.support.metrics
__consumer_offsets
_schemas
test-topic
test2-topic
</pre>
==Command line producer==
==Java producer==