卡夫卡流 - 多單實例

Question

我有一個用例做多連接的兩個主題聯接和線程數，

比方說，我有話題A（2個分區）和主題B（2分區）並運行KafkaStreams應用程序的單個實例。

我必須使用案例發現斷裂，左小姐和右小姐的兩個主題之間，所以我執行以下3個操作，

A.join(B) 
B.leftJoin(A) 
A.leftJoin(B) 

按照該文件，將有兩個任務（MAX（ 2,2））將每個拓撲結構，共6級的任務，即創建，

1. A.join(B) - two tasks created - each task is assigned two 
    partitions 
2. B.leftJoin(A) - two tasks created - each task is assigned 
    two partitions 
3. A.leftJoin(B) - two tasks created - each task is 
    assigned two partitions 

因爲我運行的一個實例，擴大規模，我計劃配置num.stream.threads = 6，每個線程將被分配一個任務。

我的上述理解是否正確？如果我錯了，請糾正我。

在此先感謝。

問候， Sathish所在

Answer 1

從匯合文檔：

卡夫卡流提供的默認的實現是 DefaultPartitionGrouper，其分配與至多一個 分區中的每個任務的每個源主題的分區的;因此，生成的任務數量等於輸入主題中分區數量最多的 。 [1]

所以，如果你不重寫partition.grouper配置，任務的數量應該爲2

鏈接： [1] http://docs.confluent.io/current/streams/developer-guide.html#optional-configuration-parameters