自Flink 1.15.0以来，PyFlink支持Pulsar源连接器。您可以参考FLINK-25530了解更多详细信息。
我一直在尝试各种示例，但我需要了解如何将PyFlink连接到Pulsar。我有Pulsar 2.8.0、Flink 1.13.1和Scala 2.11。我只需要看看如何设置PyFlink连接到Pulsar主题的参数。
请帮忙。
关于如何使用Pulsar源连接器，您可以参考PulsarSource中显示的示例了解更多详细信息。
相关内容
- 没有找到相关文章
最新更新
- 如何用管在三轴中连接两点?
- Xamarin的.列表视图上的TapGestureRecognizer在有元素时不起作用
- props是已定义的，但下面是undefined
- mysqlworkbecnh与mysql的连接
- Discordjs "createMessageComponentCollector"从其他消息中收集交互
- 我想创建一个程序，通过使用结构来计算学生的结果并打印位置
- 使用SQL窗口函数计算会话的开始和结束
- 我得到一个502坏网关错误与django应用程序在AppEngine
- 使用ngram的elasticsearch中的子词搜索不起作用
- 用 C 语言编写纸牌游戏"War"
- AWS中的 s3访问触发器
- 如何用API调用返回的数据填充Angular Boostrap Table Widget ?
- HTML CSS -在表格单元格中心像弹出一样缩放div
- 在docker桌面列表中持久化容器/应用
- Apache AuthLDAPBindDN指令接受任何字段?
- id(String)方法调用允许在插件{}脚本块错误
- python中的类、属性和方法
- 为什么float是准确的，Decimal是错误的
- 数据类型问题从Synapse到Delta表在Databricks?
- 使用列表值创建二进制矩阵
- 如何为被轻敲的键和被保持1000毫秒的键制作不同的热键
- 在MVVM Jetpack Compose上添加依赖项时重复类错误
- 列表理解不会消除重复项
- Windows -有效地将大量数据打印到终端
- R函数转换为HTML
- 裸机中的 Kubernetes 证书管理器问题：等待 HTTP-01 质询传播：状态代码"403"错误，预期'200'
- 使用钩子将状态从一个组件传递到另一个组件(不是子组件)
- 当我们使用暂存标志(--暂存)进行"npm build"时，如何在应用程序中创建"NON PRODUCTION"横幅？
- 循环访问列表，为每个项目创建新列表，然后将新列表作为参数传递给函数，但"var referenced before assignment"
- React单元测试Jest使用Typescript mount()的问题
热门标签：
javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium