kafka

注意

必须更改kafka日志目录

server.properties
log.dirs=/var/lib/kafka/data

查看kafka 数据目录

bin/kafka-log-dirs.sh --bootstrap-server localhost:9092 --describe

恢复数据

将数据放到kafka log.dirs 下重启kafka

Kafka 启动时会扫描 log.dirs 下已有的分区目录，并尝试加载日志。

如果 Topic/分区匹配正确，消息会被识别

如果 Topic 不存在或分区数量不匹配，日志会被忽略，broker 会报错

docker-compose

File not found

docker

docker run -p 80:8080 -e DYNAMIC_CONFIG_ENABLED=true --name kafka-ui  provectuslabs/kafka-ui

使用

• 查看消费进度

./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group streaming

• 重置偏移量

./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group streaming --reset-offsets --topic sxt-b-x-in --to-datetime 2025-03-14T00:00:00.000 --execute

日志一直输出debug

查看是否有logback日志包