1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.3.0/kafka_2.12-2.3.0.tgz
tar zxvf kafka_2.12-2.3.0.tgz
cd kafka
# start zookeeper
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
# start kafka
bin/kafka-server-start.sh config/server.properties &
# create topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
bin/kafka-topics.sh --list --zookeeper localhost:2181
# producer 和 consumer 可以同时开启，这样一个窗口输入，另一个窗口输出
# producer
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
> Hello world!
> Hello Kafka!
# consumer
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

1
2
3
4
5
6
cp config/server.properties config/server-1.properties
config/server-1.properties:
    broker.id=1
    port=9093
    log.dir=/tmp/kafka-logs-1
bin/kafka-server-start.sh config/server-1.properties &