Ich brauche einen Trust Store, um eine SSL-Kafka-Verbindung in Google Cloud Dataflow herzustellen. Kann ich das aus einem Bucket liefern oder gibt es eine Möglichkeit dies auf dem "lokalen Dateisystem" zu speichern?Truststore und Google Cloud Dataflow
Sie können KafkaIO.Read.withConsumerFactoryFn verwenden, um eine Factory-Funktion bereitzustellen, die zum Erstellen des Kafka-Verbrauchers aufgerufen wird. In dieser Funktion können Sie alles tun, was Ihnen gefällt, z. Sie können die Trust Store-Datei von einem GCS-Bucket herunterladen (ich würde GcsUtil dafür empfehlen) und in einer temporären Datei auf dem lokalen Datenträger speichern - AFAIK Kafka selbst unterstützt nur diese Datei auf dem lokalen Datenträger. Dann erstellen Sie manuell eine KafkaConsumer und zeigen Sie auf die Datei.