代码之家 › 专栏 › 技术社区 › Jicaar

一个卡夫卡制作人可以被多个接收器安全使用吗?

apache-flink java

Jicaar · 技术社区 · 8 年前

我有一个具有三种不同ProcessFunction的项目。如果其中任何一个发生错误,则会创建一个错误对象并将其写入侧面输出。所有三个都使用相同的输出AG作为侧输出。

我的问题是:我是否必须为每个sideoutput流创建一个新的FlinkKafkaProducer,或者我是否可以使用相同的FlinkKafkaProducer为每个sideoutput流创建一个新的接收器,因为这三个都将写入相同的错误主题?

1 回复 | 直到 8 年前

Joshua DeWald 8 年前

没有理由实际使用不同的接收器,您可以实际执行。并将其发送到单个接收器。

类似于以下内容的操作应该有效:

stream1 = source.stuff()
stream2 = source.stuff()
stream3 = source.stuff()
stream1.union(stream2, stream3).addSink(kafkaSink)

推荐文章

user29759326 · 如何返回递归函数中的最后一个值?

1 年前

malife89 · 将java中的字符串读取为正确的日期格式

1 年前

Tim · 在java中,有没有更快的方法将字节数组写入文件?

1 年前

pebble unit · 如何检查以前缀开头、以后缀结尾的属性(不是属性值)

1 年前

Nuñito Calzada · Spring Boot with JWT:访问此资源需要完全身份验证

1 年前

rudraraj · java中未声明最终变量

1 年前

Bala Ji · 以下BFS的实施效率如何?

1 年前

MineRickStar · 如何在Java中从Windows获取当前选定的应用程序

1 年前

user2649681 · 实时生成音频以写入“SourceDataLine”`

1 年前

davidalayachew · 为什么我的文件有竞争条件,即使我使用了StandardOpenOption。同步?

1 年前