kafka 集成OAUTHBEARER认证的例子
·
工程说明：
1、环境（docker && docker-compose）
| 名称 | 镜像 |
| Redis | redis:7-alpine |
| postgres | postgres:15-alpine |
| keycloak | quay.io/keycloak/keycloak:26.0.7 |
| zookeeper-oauth | confluentinc/cp-zookeeper:7.5.0 |
| kafka-oauth | confluentinc/cp-kafka:7.5.0 |
| kafka-ui | provectuslabs/kafka-ui:latest |
| schema-registry | confluentinc/cp-schema-registry:7.5.0 |
| schema-loader | alpine/curl |
| cloud-kafka-oauth-service | cloud-kafka-oauth-service:latest |
2、docker-compose运行完整服务
3、项目代码
4、schema-loader加载avsc文件
5、spring-boot程序启动日志
6、kafka-ui查看写入的数据
日志格式Avro
7、keycloak启动日志
8、keycloak的WEB UI页面
9、keycloak写入postgres的数据表
10、docker-compose启动所有服务
11、关键，kafka连接oauth获取认证的日志
12、springboot连接kafka的日志
汇聚全球AI编程工具，助力开发者即刻编程。
更多推荐
0
0- 0
已为社区贡献7条内容
所有评论(0)