通過認證生產與消費加密主題的消息
更新時間 2024-10-31 16:30:05
最近更新時間: 2024-10-31 16:30:05
分享文章
分布式消息Kafka使用SASL 認證協議來實現身份驗證的能力,加密的主題需要經過身份校驗才能正常地消費和生產消息。
-
創建用戶并配置用戶權限
進入應用用戶管理界面,新建用戶,并給用戶添加主題和消費組的權限,并且下載密鑰。詳細操作可以查看用戶指南-創建應用用戶。


-
運行生產者客戶端
如下是Java客戶端代碼示例,注意修改內容(用戶、密碼、接入地址、主題名稱)。

-
運行消費者客戶端
如下是Java客戶端代碼示例,注意修改內容(用戶、密碼、接入地址、消費組名稱、主題名稱)。
