Kafka
相关链接
https://docs.kafka-ui.provectus.io
安装部署
MacOS
安装目录
bash
|---~
|---|---Tools --
|---|---|---Kafka -- Kafka安装目录
|---|---|---|---logs -- Kafka日志目录
|---~
|---|---Tools --
|---|---|---Kafka -- Kafka安装目录
|---|---|---|---logs -- Kafka日志目录
修改配置文件
bash
log.dirs=/Users/elvea/Tools/kafka/kraft-combined-logs
log.dirs=/Users/elvea/Tools/kafka/kraft-combined-logs
手工启动
bash
#
kafka-server-start.sh "$KAFKA_HOME/config/kraft/server.properties"
#
kafka-topics.sh --bootstrap-server localhost:9092 --list
#
kafka-server-start.sh "$KAFKA_HOME/config/kraft/server.properties"
#
kafka-topics.sh --bootstrap-server localhost:9092 --list
创建启动脚本,并加入环境变量
bash
#!/bin/sh
########################################################################################################################
# Kafka
########################################################################################################################
export KAFKA_HOME=~/Tools/kafka
export PATH="$KAFKA_HOME/bin:$PATH"
# Generate Cluster ID
KAFKA_CLUSTER_ID="$($KAFKA_HOME/bin/kafka-storage.sh random-uuid)"
echo "UUID - $KAFKA_CLUSTER_ID"
# Stop Kafka
echo Stop Kafka......
call $KAFKA_HOME/bin/kafka-server-stop.sh
# Start Kraft
echo Starting Kraft......
$KAFKA_HOME/bin/kafka-storage.sh format -t "$KAFKA_CLUSTER_ID" -c "$KAFKA_HOME/config/kraft/server.properties" --ignore-formatted
# Start Kafka
echo Starting Kafka......
$KAFKA_HOME/bin/kafka-server-start.sh "$KAFKA_HOME/config/kraft/server.properties"
#!/bin/sh
########################################################################################################################
# Kafka
########################################################################################################################
export KAFKA_HOME=~/Tools/kafka
export PATH="$KAFKA_HOME/bin:$PATH"
# Generate Cluster ID
KAFKA_CLUSTER_ID="$($KAFKA_HOME/bin/kafka-storage.sh random-uuid)"
echo "UUID - $KAFKA_CLUSTER_ID"
# Stop Kafka
echo Stop Kafka......
call $KAFKA_HOME/bin/kafka-server-stop.sh
# Start Kraft
echo Starting Kraft......
$KAFKA_HOME/bin/kafka-storage.sh format -t "$KAFKA_CLUSTER_ID" -c "$KAFKA_HOME/config/kraft/server.properties" --ignore-formatted
# Start Kafka
echo Starting Kafka......
$KAFKA_HOME/bin/kafka-server-start.sh "$KAFKA_HOME/config/kraft/server.properties"
测试
bash
#
kafka-topics.sh --create --topic kraft-test --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092
#
kafka-topics.sh --bootstrap-server localhost:9092 --list
#
kafka-topics.sh --create --topic kraft-test --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092
#
kafka-topics.sh --bootstrap-server localhost:9092 --list
Windows
安装目录
bash
|---D
|---|---Tools --
|---|---|---Kafka -- Kafka安装目录
|---|---|---|---logs -- Kafka日志目录
|---D
|---|---Tools --
|---|---|---Kafka -- Kafka安装目录
|---|---|---|---logs -- Kafka日志目录
修改配置文件
bash
log.dirs=D:\Tools\Kafka\kraft-combined-logs
log.dirs=D:\Tools\Kafka\kraft-combined-logs
手工启动
bash
#
kafka-storage.sh format -t "$KAFKA_CLUSTER_ID" -c "$KAFKA_HOME/config/kraft/server.properties" --ignore-formatted
#
kafka-topics.sh --bootstrap-server localhost:9092 --list
#
kafka-storage.sh format -t "$KAFKA_CLUSTER_ID" -c "$KAFKA_HOME/config/kraft/server.properties" --ignore-formatted
#
kafka-topics.sh --bootstrap-server localhost:9092 --list
创建启动脚本,并加入环境变量
bash
@echo off
rem ##############################################################################
rem Kafka
rem ##############################################################################
setLocal
set KAFKA_HOME=D:\Tools\Kafka
rem Generate Cluster ID
call %KAFKA_HOME%\bin\windows\kafka-storage.bat random-uuid > kafka_uuid.txt
set /p KAFKA_CLUSTER_ID=<uuid.txt
echo UUID - %KAFKA_CLUSTER_ID%
rem Stop Kafka
echo Stop Kafka......
call %KAFKA_HOME%\bin\windows\kafka-server-stop.bat
rem Start Kraft
echo Starting Kraft......
call %KAFKA_HOME%\bin\windows\kafka-storage.bat format -t %KAFKA_CLUSTER_ID% -c "%KAFKA_HOME%\config\kraft\server.properties" --ignore-formatted
rem Start Kafka
echo Starting Kafka......
call %KAFKA_HOME%\bin\windows\kafka-server-start.bat "%KAFKA_HOME%\config\kraft\server.properties"
rem Clean
del kafka_uuid.txt
endLocal
@echo off
rem ##############################################################################
rem Kafka
rem ##############################################################################
setLocal
set KAFKA_HOME=D:\Tools\Kafka
rem Generate Cluster ID
call %KAFKA_HOME%\bin\windows\kafka-storage.bat random-uuid > kafka_uuid.txt
set /p KAFKA_CLUSTER_ID=<uuid.txt
echo UUID - %KAFKA_CLUSTER_ID%
rem Stop Kafka
echo Stop Kafka......
call %KAFKA_HOME%\bin\windows\kafka-server-stop.bat
rem Start Kraft
echo Starting Kraft......
call %KAFKA_HOME%\bin\windows\kafka-storage.bat format -t %KAFKA_CLUSTER_ID% -c "%KAFKA_HOME%\config\kraft\server.properties" --ignore-formatted
rem Start Kafka
echo Starting Kafka......
call %KAFKA_HOME%\bin\windows\kafka-server-start.bat "%KAFKA_HOME%\config\kraft\server.properties"
rem Clean
del kafka_uuid.txt
endLocal
测试
bash
#
kafka-topics.sh --create --topic kraft-test --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092
#
kafka-topics.sh --bootstrap-server localhost:9092 --list
#
kafka-topics.sh --create --topic kraft-test --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092
#
kafka-topics.sh --bootstrap-server localhost:9092 --list