Kafka ConsumerConnector的主题计数参数是什么

Question

我是新的阿帕奇Kafka，并尝试与例子给出。

下面的代码片段用于初始化一个ConsumerConnector，我被topic count参数搞糊涂了；它似乎会导致Kafka为该主题提供相应数量的流。然而，我尝试了几次，只有第一个流产生消息。所以，有两个问题：1。如何确定主题的计数数？2.消息分裂是如何跨越流的？

提前道谢。

    Map<String, Integer> topicCountMap = new HashMap<String, Integer>();
    **topicCountMap.put(topic, new Integer(a_numThreads));**
    Map<String, List<KafkaStream<byte[], byte[]>>> consumerMap = consumer
            .createMessageStreams(topicCountMap);
    List<KafkaStream<byte[], byte[]>> streams = consumerMap.get(topic);

Answer 1

如果我稍有错误，其他用户可以随时纠正我，但是：

我以前看过这个例子，代码通常被初始化为

topicCountMap.put(topic, new Integer(1));

其中一个是整数，因为对于给出的示例，示例主题通常只使用单个分区创建。当您的主题只有一个分区时，就没有并行能力（就像您在同一个组中有多个使用者一样，会有一些使用者实例得不到任何数据），因此，没有理由创建多个流。因此，对于这个单独的分区，只创建了一个流，这就是为什么只有第一个（也是唯一的）流生成消息的原因。