Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Updating the documents with the correct port for vboxmanage #101

Open
wants to merge 3 commits into
base: master
Choose a base branch
from
Open

Updating the documents with the correct port for vboxmanage #101

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
3cf2821
Merge pull request #1 from CenturyLinkLabs/master
levidehaan Aug 26, 2014
1b903ce
updating with the right ports
levidehaan Sep 10, 2014
1171c77
Merge pull request #2 from CenturyLinkLabs/master
levidehaan Sep 10, 2014
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 4 additions & 1 deletion kafka_server_cluster_levidehaan.pmx
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand All @@ -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
Expand Down Expand Up @@ -65,6 +67,7 @@ documentation: |
-----------------------------------------------

Kafka Consumer:

from kafka.client import KafkaClient
from kafka.consumer import MultiProcessConsumer

Expand Down