有人可以帮助我理解为什么人们使用Scala而不是Java来获取火花吗?我一直在研究,但未能找到一个可靠的答案,我知道两者都可以正常工作,因为它们都运行在JVM上,我知道scala是我们的功能和OOP语言.
谢谢
我在不同的DC上设置了2个kafka v0.10.1.0集群,并计划使用mirror-maker来保持一个作为源,另一个作为目标,我不确定如何在我的源代码时确保高可用性/主群集关闭(源kafka群集关闭的完整DC)我是否需要让我的应用程序切换到目标kafka生成消息以及源kafka返回时会发生什么?如何将其与可能丢失的消息同步恢复?
谢谢