java - 如果 kafka 流应用程序不转发事件会发生什么？
问题描述
我想知道如果kafka stream sink note不转发当前事件会发生什么？使用来自输入主题的下一个事件AbstractProcessor是否调用方法获取？process
解决方案
如果forward没有被调用，那么它就像filter()Streams DSL 方法中的 a，即从拓扑中删除记录
推荐阅读
- c++ - 如何从 std::thread 返回值
- php - 如果一个字段为空，则将第二个分配给变量
- go - 如何使用 fyne GUI 框架从代码中设置默认主题？
- scala - 获取 spark 中列（来自配置单元表）的值的平均长度以及数据类型
- spring-boot - 如何忽略在 ElasticSearch 中为 spring-data-elasticsearch 4.x、Elastic 7.6 保存几个字段
- macos - 所选文件的 Alfred 文件名
- android - 显示 json 列表中的所有数据
- java - Java 程序帮助
- python - FileNotFoundError: [Errno 2] 没有这样的文件或目录：'D:\\tester_folder'
- hibernate - Hibernate 搜索：groupby 和 in 子句