Kafka 生产者和消费者示例

这是一个使用 Go 语言实现的 Kafka 生产者和消费者示例程序，支持 SASL/SCRAM-SHA-512 认证。

功能特点

• 支持 SASL/SCRAM-SHA-512 认证
• 支持 TLS 加密连接
• 生产者支持同步发送消息
• 消费者使用消费者组模式
• 支持优雅退出
• 详细的日志记录

项目结构

. ├── config/ │ └── config.go # 配置文件处理 ├── consumer/ │ └── main.go # 消费者程序 ├── producer/ │ └── main.go # 生产者程序 ├── build/ # 编译输出目录 ├── build.sh # 构建脚本 ├── Makefile # Make 构建文件 ├── go.mod # Go 模块文件 └── go.sum # Go 依赖版本文件

环境要求

• Go 1.16 或更高版本
• 可访问的 Kafka 服务器
• 配置文件（config.yaml）

配置文件

编译

./build.sh

编译好的文件放在/build目录下.

Kafka UI配置

安装命令

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

配置如下: