[22210]Atlas Hook 无权限访问 Kafka Topic

# Atlas Hook 无权限访问 Kafka Topic：ATLAS_HOOK

# 一、问题现象 Kafka Topic 权限

Atlas Server 启动过程中，主线程初始化阶段是完整且正常的。从日志顺序可以确认，图事务、任务调度、指标模块均已成功加载。

启动阶段判断依据

以下日志只会在 Atlas Server 完成核心初始化后 才出现：

Spring 容器完成加载
JanusGraph / Solr Index 已可用
GraphTransactionAdvisor AOP 切面生效

2026-01-24 20:22:54,643 [main] INFO [GraphTransactionAdvisor.java:41] GraphTransaction intercept for org.apache.atlas.glossary.GlossaryService.assignTermToEntities
2026-01-24 20:22:54,643 [main] INFO [GraphTransactionAdvisor.java:41] GraphTransaction intercept for org.apache.atlas.glossary.GlossaryService.removeTermFromEntities
2026-01-24 20:22:54,643 [main] INFO [GraphTransactionAdvisor.java:41] GraphTransaction intercept for org.apache.atlas.glossary.GlossaryService.createCategory
2026-01-24 20:22:54,644 [main] INFO [GraphTransactionAdvisor.java:41] GraphTransaction intercept for org.apache.atlas.glossary.GlossaryService.updateCategory

1
2
3
4

# 1、服务初始化状态判断

通过上述日志可以明确判断：

检查项	状态	说明
Atlas Server 进程	正常	无启动异常
图事务 / AOP	正常	GraphTransactionAdvisor 生效
JanusGraph / Solr	正常	未出现 backend 错误
TaskManagement	正常	任务框架已启动

结论

这不是 Atlas 起不来的问题，而是启动后某个子链路失败。

# 二、异常真正出现的位置 Hook 消费线程

在 Kafka 消费线程启动后，日志中开始出现权限相关异常：

2026-01-24 20:22:55,142 [NotificationHookConsumer thread-0] WARN [NetworkClient.java:1100] [Consumer clientId=consumer-atlas-1, groupId=atlas] Error while fetching metadata with correlation id 2 : {ATLAS_HOOK=TOPIC_AUTHORIZATION_FAILED}
2026-01-24 20:22:55,144 [NotificationHookConsumer thread-0] ERROR [Metadata.java:301] [Consumer clientId=consumer-atlas-1, groupId=atlas] Topic authorization failed for topics [ATLAS_HOOK]
org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [ATLAS_HOOK]

1
2
3

关键异常特征

不是 main 线程
不是服务初始化失败
不是 consumer group 权限
是 Topic 级别拒绝
被拒绝 Topic：ATLAS_HOOK

这意味着：Hook 消费链路被 Kafka 权限直接拦断

# 三、ATLAS_HOOK 在 Atlas 架构中的角色核心通道

ATLAS_HOOK 是 Atlas 中 唯一的 Hook 事件总线 Topic。

数据流说明

Hive / HDFS / Other Hook
          ↓
      ATLAS_HOOK (Kafka Topic)
          ↓
NotificationHookConsumer
          ↓
     Atlas 元数据入库

1
2
3
4
5
6
7

# 1、写入端（Producer）

来源	说明
Hive Hook	表 / 字段 / 分区变更
HDFS Hook	目录 / 文件元数据
其他组件	Atlas 集成模块

处理办法可参考

22210:解决办法

# 七、修复结果验证验证通过

现象变化

Ranger 审计中不再出现 ATLAS_HOOK deny
NotificationHookConsumer 不再报错
Atlas Hook 消费链路恢复

#Atlas Hook #ATLAS_HOOK #TopicAuthorizationException #NotificationHookConsumer #Kafka Topic #Ranger Policy #Kerberos #BIGTOP 3.2.0

← [22211]解决办法 [22210]解决办法→