Elvea Huang

Appearance

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