Apache Kafka: Difference between revisions
Jump to navigation
Jump to search
| Line 29: | Line 29: | ||
Launch Kafka console producer |
Launch Kafka console producer |
||
<pre> |
<pre> |
||
./bin/kafka-console-producer.sh --broker-list localhost:2181 --topic |
./bin/kafka-console-producer.sh --broker-list localhost:2181 --topic test |
||
</pre> |
</pre> |
||
Launch Kafka console consumer |
Launch Kafka console consumer |
||
<pre> |
<pre> |
||
./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic |
./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test |
||
</pre> |
</pre> |
||
Revision as of 15:01, 5 April 2014
Apache Kafka is Publish-Subscribe messaging rethought as a distributed commit log.
Clients en Perl, Python, Node.js, C, C++, Scala ...: https://cwiki.apache.org/confluence/display/KAFKA/Clients
First steps with Kafka
see Quickstart
cd kafka
Launch Zookeeper
./bin/zookeeper-server-start.sh ./config/zookeeper.properties
Launch Kafka server
./bin/kafka-server-start.sh ./config/server.properties
Launch Zookeeper shell
./bin/zookeeper-shell.sh localhost:2181
Launch Kafka console producer
./bin/kafka-console-producer.sh --broker-list localhost:2181 --topic test
Launch Kafka console consumer
./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test
Stop all
./bin/kafka-server-stop.sh ./bin/zookeeper-server-stop.sh