希望这是一个快速而简单的问题。现在我有一个应用程序,在同一个流中有两个独特的任务。当整个应用程序运行时,两个任务之间的分区不平衡,这是一个问题,因为其中一个任务需要更多的资源(内存/cpu)
为了解决这个问题,我在应用程序中使用不同的流生成器创建了两个独特的流,并分别启动它们。通过这样设置,分区以我期望的方式进行了平衡。
kafkaStreams0 = new KafkaStreams(kafkaStreamsBuilder0.build(), streamsProperties0)
kafkaStreams1 = new KafkaStreams(kafkaStreamsBuilder1.build(), streamsProperties1)
kafkaStreams0.start()
kafkaStreams1.start()
我在流属性中为每个应用程序提供它们自己的应用程序id。关于这一点似乎是一个黑客,但我找不到任何文件,这是否是一个有效的解决方案。
注意:我希望避免将这些应用程序拆分为两个应用程序,因为我不想增加操作开销。
暂无答案!
目前还没有任何答案,快来回答吧!