Confluent Cloud Kafka - 审计日志集群:Sink Connector [英] Confluent Cloud Kafka - Audit Log Cluster : Sink Connector

问题描述

对于托管在 Confluent Cloud 中的 Kafka 集群，会创建一个审核日志集群.似乎有可能将 Sink 连接器挂接到该集群并从confluent-audit-log-events"中排出事件.主题.

For Kafka cluster hosted in Confluent Cloud, there is an Audit Log cluster that gets created. It seems to be possible to hook a Sink connector to this cluster and drain the events out from "confluent-audit-log-events" topic.

但是，当我运行连接器执行相同操作时，我遇到了以下错误.

However, I am running into the below error when I run the connector to do the same.

org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [connect-offsets]

在我的 connect-distributed.properties 文件中，我的设置如下:

In my connect-distributed.properties file, I have the settings as :

offset.storage.topic=connect-offsets
offset.storage.replication.factor=3
offset.storage.partitions=3

需要授予哪些额外的权限，连接器才能在集群中创建所需的主题?connect-distributed.properties 文件中使用的密钥/机密是与此集群的服务帐户关联的有效密钥/机密.

What extra permission/s needs to be granted so that the connector can create the required topics in the cluster? The key/secret being used in the connect-distributed.properties files is a valid key/secret that is associated to the service account for this cluster.

此外，当我使用相同的键(如上)在控制台中运行使用者时，我能够很好地读取审核日志事件.

Also, when I run the consumer in the console using the same key (as above) , I am able to read the audit log events just fine.

推荐答案

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

It's confirmed that this feature (hooking up a connector to the Audit Log cluster) is not supported at the moment in Confluent Cloud. This feature may be available later this year at some point.

这篇关于Confluent Cloud Kafka - 审计日志集群:Sink Connector的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！