-
Notifications
You must be signed in to change notification settings - Fork 0
/
starter.bat
33 lines (33 loc) · 1.78 KB
/
starter.bat
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
REM AUTHOR brianblaze14
@echo off
set KF_JAVA_HOME=D:\Applns\openlogic-openjdk-11.0.8+10-windows-x64\openlogic-openjdk-11.0.8+10-win-x64\bin
set KFDROP_PATH=./kafdrop
set KF_ROOT_PATH=./kafka_2.12-3.2.0
echo %KF_ROOT_PATH%
echo "************Starting Zookeeper************"
start /d "%KF_ROOT_PATH%" bin\windows\zookeeper-server-start.bat config/zookeeper.properties
echo "************Zookeeper is up************"
echo "************Starting Kafka************"
pause
start /d "%KF_ROOT_PATH%" bin\windows\kafka-server-start.bat config/server.properties
echo "************Kafka is up************"
echo "************Create topic and press any key to continue************"
set /p topic=Enter Topic name:
echo %topic%
pause
echo "************Creating topic************"
start /d "%KF_ROOT_PATH%" bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic %topic%
echo "************Topic created successfully************"
pause
echo "************Opening Producer console************"
start /d "%KF_ROOT_PATH%" bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic %topic%
echo "************Opened kafka producer console successfully************"
pause
echo "************Opening Consumer console************"
start /d "%KF_ROOT_PATH%" bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic %topic% --from-beginning
echo "************Opened kafka consumer console successfully************"
pause
echo "************Enabling Kafdrop Viewer************"
start /d "%KFDROP_PATH%" %KF_JAVA_HOME%\java -jar kafdrop-3.30.0.jar --server.port=9001 --management.server.port=9001 --kafka.brokerConnect=localhost:9092
echo "************Kafdrop Viewer (http://localhost:9001)***********************"
pause