对于托管在 Confluent Cloud 中的 Kafka 集群，会创建一个 Audit Log 集群。似乎可以将 Sink 连接器连接到该集群并从“confluent-audit-log-events”主题中排出事件。
但是，当我运行连接器执行相同操作时，我遇到了以下错误。
org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [connect-offsets]
在我的 connect-distributed.properties 文件中，我的设置为：
offset.storage.topic=connect-offsets
offset.storage.replication.factor=3
offset.storage.partitions=3
需要授予哪些额外权限，以便连接器可以在集群中创建所需的主题？connect-distributed.properties 文件中使用的密钥/密钥是与此集群的服务帐户关联的有效密钥/密钥。
此外，当我在控制台中使用相同的键（如上）运行消费者时，我能够很好地读取审计日志事件。