我最近一直在与Kafka一起工作，对某个消费群体下的消费者有些困惑。混淆的中心是将使用者实现为进程还是线程。对于这个问题，假设我正在使用高级消费者。

让我们考虑一个我尝试过的场景。在我的主题中，有2个分区（为简单起见，我们假设复制因子仅为1）。我创建了一个消费者（ConsumerConnector）过程consumer1与组group1，然后创建尺寸2的主题计数地图，然后产生了2个消费者线程consumer1_thread1和consumer1_thread2该过程下。看起来好像consumer1_thread1正在消耗分区，0而且consumer1_thread2正在消耗分区1。这种行为是否总是确定性的？下面是代码片段。类TestConsumer是我的使用者线程类。

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

    executor = Executors.newFixedThreadPool(2);

    int threadNumber = 0;
    for (final KafkaStream stream : streams) {
        executor.submit(new TestConsumer(stream, threadNumber));
        threadNumber++;
    }
    ...

现在，让我们考虑另一个场景（我还没有尝试过，但是很好奇），其中我启动了2个消费者进程，consumer1并且consumer2它们都具有相同的组，group1并且每个进程都是一个单线程进程。现在我的问题是：

1. 在这种情况下，两个独立的使用者进程（仍然在同一个组中）如何与分区相关？与上述单进程多线程方案有何不同？

2. 通常，使用者线程或进程如何与主题中的分区映射/相关？

3. Kafka文档确实指出，消费者组下的每个消费者都将使用一个分区。但是，这是指使用者线程（例如上面的代码示例）还是独立的使用者进程？

4. 关于将消费者实现为流程还是线程，我在这里是否缺少任何微妙的东西？提前致谢。