将 Kafka 集群审计日志获取到 GCP 日志记录有哪些不同的方法？
What are the different ways to get Kafka Cluster Audit log to GCP Logging?
将 Kafka 集群审计日志获取到 GCP 日志记录有哪些不同的方法？
谁能分享更多关于我如何实现它的信息？
谢谢！
假设您有权访问必要的主题（据我了解，审计主题未存储在您自己的集群中），要从 Kafka 中获取数据，您需要一个消费者。这可以是任何语言。
要将数据导入 Cloud Logging，您需要使用 its API。
也就是说，您可以使用任何兼容的 Kafka 客户端和云日志客户端对。
比如你could write or find a Kafka Connect Sink connector that wraps the Java Cloud Logging client.
将 Kafka 集群审计日志获取到 GCP 日志记录有哪些不同的方法？ 谁能分享更多关于我如何实现它的信息？
谢谢！
假设您有权访问必要的主题（据我了解，审计主题未存储在您自己的集群中），要从 Kafka 中获取数据，您需要一个消费者。这可以是任何语言。
要将数据导入 Cloud Logging，您需要使用 its API。
也就是说，您可以使用任何兼容的 Kafka 客户端和云日志客户端对。
比如你could write or find a Kafka Connect Sink connector that wraps the Java Cloud Logging client.