我需要编写一个客户端，它将事件插入 kafka 中。我需要在单个事务中的多个主题中插入多个事件。我想知道是否可以通过 kafka 连接器，或者我应该在 java 中创建一个新的生产者，该生产者将开始并提交事务。
很遗憾，在 Connect 中无法实现，请参阅 https://issues.apache.org/jira/browse/KAFKA-6080
相关内容
- 没有找到相关文章
最新更新
- 如何用管在三轴中连接两点?
- 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