Truststore和Google Cloud Dataflow

Question

我需要使用信任存儲在Google Cloud Dataflow中創建SSL Kafka連接。我可以從一個存儲桶提供此信息，還是可以將其存儲在「本地文件系統」上？

Answer 1

您可以使用KafkaIO.Read.withConsumerFactoryFn來提供將被調用來創建卡夫卡用戶的工廠函數。在這個功能中，你可以自由地做任何你喜歡的事情，例如您可以從GCS存儲桶下載信任存儲文件（我會建議使用GcsUtil）並將其保存到本地磁盤上的臨時文件 - AFAIK Kafka本身僅支持在本地磁盤上存儲此文件。然後手動創建一個KafkaConsumer並將其指向該文件。