代码之家  ›  专栏  ›  技术社区  ›  user1578872

带有AdminClient的卡夫卡2.1指标

  •  0
  • user1578872  · 技术社区  · 5 年前

    我正在使用AdminClient进行卡夫卡监控。我们正在使用SASL和授权插件。我用于从本主题获取数据的用户已被授予访问权限,我可以获取偏移、滞后等其他详细信息。但是,我无法执行describeConfigs。

    代码:

    final Collection<ConfigResource> resources = new ArrayList<>();
    resources.add(new ConfigResource(Type.TOPIC, "topic1"));
    final Map<ConfigResource,Config>configMap=
    adminClient.describeConfigs(resources).all().get();
    

    错误:

    JAVAutil。同时发生的执行例外: 组织。阿帕奇。卡夫卡。常见的错误。主题授权例外:不是 授权访问主题:[主题授权失败。]

    我错过什么了吗?

    0 回复  |  直到 5 年前