雅虎开发了Pulsar,pub-sub消息系统,并将其作为开源软件.它现在是Apache的孵化项目.由于卡夫卡也用于同一目的.想知道,卡夫卡超过Pulsar的主要加分和减分.
在Kafka Stream库中,我想知道KTable和GlobalKTable之间的区别.
同样在KStream类中,有两种方法leftJoin()和outerJoin().这两种方法有什么区别呢？
我读过KStream.leftJoin,但没有找到确切的区别.
我正在使用Spark 2.1的结构化流（内部使用Hive 1.2.1 jar）。我正在尝试为Hive开发ForEachWriter，以通过JDBC连接器将流数据写入Hive。
在我的群集上，我有Hive 1.1.0。
如果我使用版本1.2.1的Hive jdbc jar，则由于客户端和服务器版本的Hive不匹配，我将遇到以下异常：
Required field 'client_protocol' is unset!
如果我使用版本1.1.0的Hive jdbc jar，则在Spark中出现异常，如下所示：
Caused by: java.lang.NoSuchFieldError: METASTORE_CLIENT_SOCKET_LIFETIME
在初始化HiveContext in时它来了SparkSession。