Confluent Cloud Kafka - 审计日志集群：Sink Connector

Question

对于托管在 Confluent Cloud 中的 Kafka 集群，会创建一个审计日志集群。似乎可以将 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

需要授予什么额外的 permission/s 连接器才能在集群中创建所需的主题？ connect-distributed.properties 文件中使用的 key/secret 是与此集群的服务帐户相关联的有效 key/secret。

此外，当我运行控制台中的消费者使用相同的密钥（如上所述）时，我能够很好地读取审计日志事件。

Answer 1

已确认 Confluent Cloud 目前不支持此功能（将连接器连接到审计日志集群）。此功能可能会在今年晚些时候推出。

Confluent Cloud Kafka - Audit Log Cluster : Sink Connector