diff --git a/kafka_server_cluster_levidehaan.pmx b/kafka_server_cluster_levidehaan.pmx index 08a1751..ab0dab7 100644 --- a/kafka_server_cluster_levidehaan.pmx +++ b/kafka_server_cluster_levidehaan.pmx @@ -7,7 +7,7 @@ documentation: | You will need to expose port 9050 and 9051 on virtualbox in order to connect with python. - VBoxManage controlvm panamax-vm natpf1 kafka,tcp,,9050,,9051 + VBoxManage controlvm panamax-vm natpf1 kafka,tcp,,9050,,9050 If you're just getting started with Kafka you can try out sending massages with Kafka Python. Here are some directions to get you started. @@ -30,11 +30,13 @@ documentation: | Install kafka-python + pip install kafka-python --------------------------- Kafka Emitter: + from kafka.client import KafkaClient from kafka.consumer import SimpleConsumer from kafka.producer import SimpleProducer, KeyedProducer @@ -65,6 +67,7 @@ documentation: | ----------------------------------------------- Kafka Consumer: + from kafka.client import KafkaClient from kafka.consumer import MultiProcessConsumer