程序员经验分享-hwhale

Truststore 和 Google Cloud Dataflow

2023-12-12

我需要使用信任存储在 Google Cloud Dataflow 中建立 SSL Kafka 连接。我可以从存储桶中提供这个，还是有办法将其存储在“本地文件系统”上？


您可以使用KafkaIO.Read.withConsumerFactoryFn提供一个工厂函数，该函数将被调用以创建 Kafka 消费者。在该功能中，您可以自由地做任何您喜欢的事情，例如您可以从 GCS 存储桶下载信任存储文件（我建议使用GcsUtil为此）并将其保存到本地磁盘上的临时文件 - AFAIK Kafka 本身仅支持将此文件保存在本地磁盘上。然后手动创建一个KafkaConsumer并将其指向该文件。

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

googleclouddataflow

Truststore 和 Google Cloud Dataflow 的相关文章

随机推荐

  • 为什么在使用初始化器、构造函数和方法调用时打印语句按此顺序执行？

    这是我正在运行的代码 该代码的输出是 4 2 1 3 有人可以解释一下为什么结果是按这个顺序打印的 public class goFuncTest goFuncTest System out print 1 System out print

  • asp.net MVC webmatrixmembershipprovider 启动

    从 mvc2 mvc3 迁移后有一些小问题 我在调用 Membership GetAllUsers 时遇到以下问题 似乎不是 System Web Security SqlMembershipProvider WebMatrix WebDa

  • 使用 json_encode() 时删除数组索引引用

    我使用 jQuery 制作了一个小应用程序datepicker 我从 JSON 文件中设置不可用的日期 如下所示 dates 2013 12 11 2013 12 10 2013 12 07 2013 12 04 我想检查给定的日期是否已在

  • 如何在给定 XSD 的情况下在 C# 中进行多态反序列化？

    我给出以下内容 1 XML 架构 XSD 文件 使用 XSD EXE 工具编译为 C 类 2 RabbitMQ 消息队列 包含 XML 格式中定义的任何类型的格式良好的消息 以下是不同消息的两个片段

  • Haskell：基础阅读 Int

    目标是用 Haskell 编写 Nim 游戏作为学校作业 我是 Haskell 新手 当我尝试读取输入时会出现奇怪的行为 目标是读取两个整数 它不是打印第一条消息 然后提示 然后继续第二条消息 而是只打印两条消息 而我无法提供正确的输入 这

  • 从单独的线程类获取数据时不显示进度对话框

    我正在使用单独的线程从 url 获取 json 对象 但问题是我想在获得结果时显示进度对话框 我创建了一个进度对话框 并在线程执行之前和之后调用显示和关闭 但未显示进度对话框 这是我调用线程的方式 private void getRecor

  • 如何使用 web3js 发送 ERC20 令牌

    我目前使用的是 0 2x x 版本的 Web3 JavaScript API 我通过在 Solidity 中创建智能合约 在 REMIX IDE 上 来部署自定义 ERC20 代币 我安装了 MetaMask 并进行了测试https wal

  • 在引导 Angular2 应用程序之前发出 AJAX 请求 [重复]

    这个问题在这里已经有答案了 在我的 Angular2 应用程序中 我需要根据此调用的结果从 AuthenticationService 和引导应用程序调用某些函数 问题是 AuthenticationService 依赖于来自 Angula

  • 在 MATLAB 中计算实际频率值与 FFT 绘图索引之间的关系时出现混乱

    我知道有很多类似的问题 但我仍然无法找出答案 假设 MATLAB 中有时间信号 t 0 1 44100 1 和频率为 500Hz 的余弦信号 x cos 2 pi 500 t 现在 我正在尝试绘制使用以下方法获得的幅度谱fft信号 x 上的

  • 点击事件触发两次

    我试图在单击标签文本时运行某些函数 但单击事件触发了两次 HTML

  • 排除/覆盖 npm 提供的类型

    我有一个 npm 包 里面写得不好 打字也过时了 我已经编写了自己的类型 现在我想知道是否可以以某种方式从 npm 包中排除原始类型 它不是一个简单的接口扩展 原来的在这一点上基本上是垃圾 当然 使用 tsconfig json 中的排除列

  • 非常基本的 dcg prolog 语法

    我试图理解序言和定语从句语法 但我很难理解它们 我真的很想了解如何使用 dcg 语法 这里我举两个例子 第一个实际上是来自该论坛上另一个问题的代码 但还有一个附加问题 代码如下 s gt first operator second firs

  • Android studio：如何使用 ViewPager 添加选项卡

    我想在片段中添加带有 pagerview 可滚动 的选项卡 public class MyFragment extends Fragment private FragmentTabHost tabHost Override public V

  • Symfony2 无法正确保存会话

    我在 Symfony 在每个页面加载时创建一个新会话而不是跨请求携带数据时遇到问题 config yml 中会话部分的 auto start 设置为 false 常规 php 会话工作正常 只有在 symfony 中运行时我才会遇到问题 例

  • 最大值可以以两位数精度（2位精度）存储在Java浮点数中吗？

    我如何找到可以存储在 float 中的最大两位小数精度值 根据我的理解 在 32 位浮点数中 我们有 24 23 1 来存储不包括指数的数字 2 24 是我们可以存储的最大值 提前致谢 斯里拉曼 2 24 是您可以准确存储的最大整数 您可以

  • 单击时标签改变颜色

    我有一个 VBA Excel 用户单击标签 Active X 文本标签 来执行一些操作 标签属性为 BackStyle 透明 但当用户单击时 标签保持不透明 如白色或设置 BackColor 属性的任何内容 当用户点击标签时如何保持透明 不

  • 如何使用 Dask.array 高效地将大型 numpy 数组发送到集群

    我的本地计算机上有一个大型 NumPy 数组 我想将其与集群上的 Dask array 并行化 import numpy as np x np random random 1000 1000 1000 然而 当我使用 dask array

  • Entity Framework Core 中没有嵌套结果[重复]

    这个问题在这里已经有答案了 我在使用 EF 的 C 中有一个奇怪的行为 这是一个带有 EF Core 1 1 0 的 NET Core 项目 Microsoft EntityFrameworkCore SqlServer 1 1 0 Mic

  • 如何使用 Gson 库将 java.util.List 序列化为 Json？

    在我的 servlet 中 我有以下代码 response setContentType application json set json content type PrintWriter out response getWriter E

  • Truststore 和 Google Cloud Dataflow

    我需要使用信任存储在 Google Cloud Dataflow 中建立 SSL Kafka 连接 我可以从存储桶中提供这个 还是有办法将其存储在 本地文件系统 上 您可以使用KafkaIO Read withConsumerFactory

热门标签