KStream-KStream加入vs KStream-KTable加入表现

Question

我有一个Kafka Streams应用程序，它从少量主题获取数据并加入数据并将其放入另一个主题中。

卡夫卡配置：

5 kafka brokers 
Kafka Topics - 15 partitions and 3 replication factor. 

的几百万美元的记录被消费/制造每隔一小时。

我正在做KStream-KStream加入，它创建2个内部主题。 KStream-KTable连接将创建1个内部主题+1表。

在性能和其他因素方面哪个更好？

Answer 1

的选择是不是性能的问题，而是语义一个问题：应该怎样联接结果是什么？这两个连接都会计算出不同的结果，因此您应该选择符合应用程序需求的语义。

不同的语义都记录在CP文档和AK维基：

• https://docs.confluent.io/current/streams/developer-guide.html#joining
• https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Streams+Join+Semantics