目录
目录
目录
第一章 安装包下载
第二章 各服务启动
第一章 安装包下载
ES、Kibana、Logstash下载链接
Past Releases of Elastic Stack Software | Elastic
IK分词器、拼音插件下载链接
Index of:
Canal下载链接
Release v1.1.7 · alibaba/canal · GitHub
Kafka下载链接
https://kafka.apache.org/community/downloads/#280
第二章 服务启动
启动顺序:Elasticsearch -> Kibana -> Zookeeper -> Kafka -> Canal -> Kafka 消息队列
Elasticsearch启动命令:
# 进入 Elasticsearch 目录 cd D:\elasticsearch-8.19.19\bin .\elasticsearch.batKibana启动命令:
# 进入 Kibana 目录 cd D:\kibana-8.19.19\bin .\kibana.batZookeeper启动命令:
# 进入 Kafka 目录下的 Windows 脚本目录 cd D:\kafka_2.13-2.8.0\bin\windows .\zookeeper-server-start.bat ..\..\config\zookeeper.propertiesKafka启动命令:
# 进入 Kafka 目录下的 Windows 脚本目录 cd D:\kafka_2.13-2.8.0\bin\windows .\kafka-server-start.bat ..\..\config\server.propertiesCanal启动命令:
# 进入 Canal 的 bin 目录 cd D:\canal-1.1.7\canal.deployer-1.1.7\bin .\startup.batKafka 消息队列启动命令:
# 进入 Kafka 目录下的 Windows 脚本目录 本地测试使用,生产环境无需 cd D:\kafka_2.13-2.8.0\bin\windows kafka-console-consumer.bat --topic 你的topic名称 --bootstrap-server localhost:9092 # topic名称:Cancl的conf/example/instance.properties 里找 canal.mq.topic 配置项本地脚本一键启动命令(start_all.bat):
@echo off chcp 65001 >nul echo ======================================== echo 启动 Elasticsearch... start "Elasticsearch" cmd /k "cd /d D:\elasticsearch-8.19.19\bin && .\elasticsearch.bat" timeout /t 15 echo 启动 Kibana... start "Kibana" cmd /k "cd /d D:\kibana-8.19.19\bin && .\kibana.bat" timeout /t 15 echo 启动 ZooKeeper... start "ZooKeeper" cmd /k "cd /d D:\kafka_2.13-2.8.0\bin\windows && .\zookeeper-server-start.bat ..\..\config\zookeeper.properties" timeout /t 10 echo ======================================== echo 清理 ZooKeeper 中的 Kafka 残留节点... cd /d D:\kafka_2.13-2.8.0\bin\windows echo delete /brokers/ids/0 | .\zookeeper-shell.bat localhost:2181 >nul 2>&1 echo 清理完成! echo ======================================== echo 启动 Kafka... start "Kafka" cmd /k "cd /d D:\kafka_2.13-2.8.0\bin\windows && .\kafka-server-start.bat ..\..\config\server.properties" timeout /t 10 echo 启动 Canal... start "Canal" cmd /c "cd /d D:\canal-1.1.7\canal.deployer-1.1.7\bin && .\startup.bat" timeout /t 10 echo 启动 Kafka 消费者(实时查看消息)... echo 请先确认 Canal 配置的 Topic 名称! echo. echo 查看 Topic 名称: echo type D:\canal-1.1.7\canal.deployer-1.1.7\conf\example\instance.properties ^| findstr canal.mq.topic echo. echo 请输入你的 Topic 名称(按回车键继续,默认 canal-topic): set /p TOPIC_NAME=Topic 名称: if "%TOPIC_NAME%"=="" set TOPIC_NAME=canal-topic echo 使用 Topic: %TOPIC_NAME% start "Kafka-Consumer" cmd /k "cd /d D:\kafka_2.13-2.8.0\bin\windows && .\kafka-console-consumer.bat --topic %TOPIC_NAME% --bootstrap-server localhost:9092" echo ======================================== echo 所有服务已启动! echo. echo 端口信息: echo Elasticsearch: 9200 echo Kibana: 5601 echo ZooKeeper: 2181 echo Kafka: 9092 echo Canal: 11111 echo. echo 消费者窗口已打开,请在 MySQL 中执行变更操作! echo. pause