Apache Kafka: Difference between revisions
Jump to navigation
Jump to search
| Line 6: | Line 6: | ||
=First steps with Kafka= |
=First steps with Kafka= |
||
see [ |
see [https://kafka.apache.org/documentation.html#quickstart Quickstart] |
||
<pre> |
<pre> |
||
| Line 22: | Line 22: | ||
</pre> |
</pre> |
||
Create a topic |
|||
| ⚫ | |||
<pre> |
<pre> |
||
./bin/ |
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test |
||
</pre> |
</pre> |
||
| Line 42: | Line 42: | ||
./bin/kafka-server-stop.sh |
./bin/kafka-server-stop.sh |
||
./bin/zookeeper-server-stop.sh |
./bin/zookeeper-server-stop.sh |
||
</pre> |
|||
==Extra== |
|||
| ⚫ | |||
<pre> |
|||
./bin/zookeeper-shell.sh localhost:2181 |
|||
</pre> |
</pre> |
||
Revision as of 15:08, 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
Create a topic
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
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
Extra
Launch Zookeeper shell
./bin/zookeeper-shell.sh localhost:2181