我想知道这个简单的问题： foreachRDD 是否保持顺序读取具有 1 个分区的 kafka 主题？ 谢谢。
如果其他人想知道同样的问题，答案是肯定
的相关内容
- 在不同的Kafka消费者组中混合手动和自动分区分配
- Kafka这个主题分区没有领袖，因为我们正处于领袖选举的中间
- kafka分区负载过大(单个分区额外负载)
- kafka流分区分配不均
- 重新部署后，kafka流抱怨一个内部主题有无效的分区.为什么会发生这种情况?
- Kafka Consumer在spring中我可以重新分配分区编程吗?
- 同一个消费者组中不同的kafka topic具有不同数量的分区
- 通过农场暂停Kafka消费者分区
- kafka API，用于从具有相同分区键的topic中读取组中的kafka消息
- 如何使用kafka分区将kafka负载分配到openshift pod中
- 当应用程序在本地Kafka实例上运行时， Topic分区显示为null
- Spark结构化流生成器是否在Spark分区之间或仅在分区内使用Kafka默认分区器?
- 处理kafka中每个消费者订阅分区时消费者死亡的情况
- 如何在JS中为Kafka消费者获得分配分区
- 如果内核数量大于Kafka分区数量，Spark结构化流是否会从动态分配中受益?
- Kafka主题分区缺失偏移量
- 用于春季云流的DLQ的分区Kafka主题
- kafka + 此服务器不是该主题分区 + kafka 生产者的领导者
- 如何在读取多分区 kafka 主题时激发结构化流使用者的启动和调用
- 添加新的分区Kafka 0.8.1.1
最新更新
- 我如何轻松地重新安装所有卸载的VS Code扩展，他们的文件仍然徘徊在我的~/.vscode /扩展文件夹吗?<
- 使用MS Graph API在应用注册中添加更多应用角色
- PAC文件未正确筛选网站
- 返回一个字典，每个字符都有多个实例
- AWS S3 -仅Zip文件对象，而不是路径
- 公共api如何处理CORS起源和jwt ?
- 如何摆脱实际上"duplicates"几乎等同的调用行，实际上只切换了部分列数据？
- 如何在换行时中断文本?
- 使用流JAVA 8将map转换为特定的dto对象
- React Typescript：重构代码后无法过滤数组
- pyalgotrade退出订单事件(onExitOk)的问题
- 如何从Lucene文档中打印所有术语?
- 使用jQuery通过span类获取检查元素
- 如果数据在列表中，如何过滤请求中的数据?
- 是否可以使用javascript或python访问whatsapp消息数据库历史记录?
- 为什么在版本 5 中找不到松树脚本的"ta.sqrt"？
- 检查String是否包含List中的任何项
- Firebase Checkout Timer
- Pythonnet中的c#扩展和Linq
- 你好，这是大学学习编程的第一天
- 为什么单元测试一个图像字段使用SimpleUploadedFile创建多个图像?
- 从文件中删除空白而不是从目录中删除空白会抛出错误
- 如何调用异步函数之前的组件呈现在reactjs?
- scikit-learn版本不匹配__version__ '和' pip show scikit-learn '.<
- 雪花云数据平台哈希MD5或SHA256
- Traefik filter portainer 作为 docker 群中的"disabled container"
- Pandas数据框架，如何根据其他行的值替换部分行
- 如何安装Tensorflow和CUDA驱动程序?
- 如何创建带有域名和可导出过程列表的COBOL模块
- Pixi js对一个元素进行两次旋转(如何添加类似包装器的东西)
热门标签：
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