Слияние кода завершено, страница обновится автоматически
1、首先安装 zookeeper
2、下载kafka
wget https://mirrors.cnnic.cn/apache/kafka/2.1.0/kafka_2.11-2.1.0.tgz
解压：
tar zxf kafka_2.11-2.1.0.tgz
3、修改配置
cd kafka_2.11-2.1.0/config/
vim server.properties
kafka最为重要三个配置依次为：broker.id、log.dir、zookeeper.connect
参数详细说明：
https://blog.csdn.net/lizhitao/article/details/25667831
4、启动
cd /Users/onlyone/software/kafka/kafka_2.11-2.1.0
bin/kafka-server-start.sh config/server.properties &
停止kafka
bin/kafka-server-stop.sh
5、检测
➜ jps
41505 QuorumPeerMain
66244 Jps
64472 Kafka
252
6、测试
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1
bin/kafka-topics.sh --list --zookeeper localhost:2181
bin/kafka-topics.sh --describe --zookeeper localhost:2181
运行结果：
Topic:test1 PartitionCount:1 ReplicationFactor:1 Configs:
Topic: test1 Partition: 0 Leader: 1 Replicas: 1 Isr: 1
参数解析：https://www.cnblogs.com/shengulong/p/9013282.html
bin/kafka-console-producer.sh --broker-list 192.168.0.14:9092 --topic test1
注意：首次，topic不存在时，会自动创建
上面命令是在控制台输入要发送的消息，“回车”单条消息结束。
echo '{"name":"Steve", "title":"Captain America"}' | bin/kafka-console-producer.sh --broker-list 192.168.0.14:9092 --topic test1
将发送的消息放在执行命令中。
bin/kafka-console-consumer.sh --bootstrap-server 192.168.0.14:9092 --topic test1 --from-beginning
Вы можете оставить комментарий после Вход в систему
Неприемлемый контент может быть отображен здесь и не будет показан на странице. Вы можете проверить и изменить его с помощью соответствующей функции редактирования.
Если вы подтверждаете, что содержание не содержит непристойной лексики/перенаправления на рекламу/насилия/вульгарной порнографии/нарушений/пиратства/ложного/незначительного или незаконного контента, связанного с национальными законами и предписаниями, вы можете нажать «Отправить» для подачи апелляции, и мы обработаем ее как можно скорее.
Опубликовать ( 0 )