官术网_书友最值得收藏!

Running Kafka

There are two ways to run Kafka, depending on whether we install it directly or through Confluent Platform.

If we install it directly, the steps to run Kafka are as follows.

For macOS users, your paths might be different if you've installed using brew. Check the output of brew install kafka command for the exact command that you can use to start Zookeeper and Kafka.

Go to the Kafka installation directory (/usr/local/kafka for macOS users and /opt/kafka/ for Linux users), as in the example:

> cd /usr/local/kafka

First of all, we need to start Zookeeper (the Kafka dependency with Zookeeper is and will remain strong). Type the following:

> ./bin/zookeeper-server-start.sh ../config/zookeper.properties

ZooKeeper JMX enabled by default

Using config: /usr/local/etc/zookeeper/zoo.cfg

Starting zookeeper ... STARTED

To check whether Zookeeper is running, use the lsof command over the 9093 port (default port) as follows:

> lsof -i :9093

COMMAND PID USER FD TYPE DEVICE SIZE/OFF NODE NAME

java 12529 admin 406u IPv6 0xc41a24baa4fedb11 0t0 TCP *:9093 (LISTEN)

Now run the Kafka server that comes with the installation by going to /usr/local/kafka/ for macOS users and /opt/kafka/ for Linux users:

> ./bin/kafka-server-start.sh ./config/server.properties

Now there is an Apache Kafka broker running in your machine.

Remember that Zookeeper must be running on the machine before starting Kafka. If you don't want to start Zookeeper manually every time you need to run Kafka, install it as an operation system auto-start service.

主站蜘蛛池模板: 蒲城县| 休宁县| 丹凤县| 吴堡县| 万全县| 芜湖县| 左贡县| 高雄市| 运城市| 佛冈县| 读书| 涟源市| 普兰县| 延长县| 阆中市| 龙州县| 溧水县| 建德市| 塔河县| 尚义县| 镇康县| 红安县| 扬中市| 军事| 滁州市| 万山特区| 华坪县| 增城市| 蚌埠市| 江口县| 漯河市| 东山县| 兴宁市| 共和县| 临清市| 贵定县| 西乌珠穆沁旗| 阿克苏市| 东乡县| 赤壁市| 确山县|