apache-kafka - 将 Kafka 集群审计日志获取到 GCP 日志记录的不同方法有哪些？

Question

将 Kafka 集群审计日志获取到 GCP 日志记录的不同方法有哪些？谁能分享更多关于我如何实现它的信息？

谢谢！

Answer 1

假设您可以访问必要的主题（据我了解，审计主题并未存储在您自己的集群中），要从 Kafka 中获取数据，您需要一个消费者。这可以是任何语言。

要将数据导入 Cloud Logging，您需要使用其 API。

---

话虽如此，您可以使用任何您愿意使用的兼容的 Kafka 客户端和云日志记录客户端对。

例如，您可以编写或查找包装Java Cloud Logging 客户端的 Kafka Connect Sink 连接器。