我有一个Kafka主题，有10个分区。我计划在不同的服务器上部署两个应用程序。一个应用程序将读取分区0到4。而另一个将读取分区5到9。
部署1

@KafkaListener(topicPartitions =
        { @TopicPartition(topic = "testpartition", partitions = { "0", "1","2", "3","4" })

              })
    public void receive(ConsumerRecord record) {
        System.out.println(String.format("Listener 1 -Topic - %s, Partition - %d, Value: %s", kafkaTopic, record.partition(), record.value()));
    }

部署2

@KafkaListener(topicPartitions =
        { @TopicPartition(topic = "testpartition", partitions = { "5", "6","7", "8","9" })

              })
    public void receive(ConsumerRecord record) {
        System.out.println(String.format("Listener 2 -Topic - %s, Partition - %d, Value: %s", kafkaTopic, record.partition(), record.value()));
    }

因此，我们将有两个用户组，因为应用程序分别部署在不同的服务器上。
由于每个应用程序都使用不同的分区，这是否会导致Kafka主题上不需要的消息复制？
将所有消息复制两次。如果是这种情况，那么会有消息重复吗？
这是在分布式环境中部署使用者应用程序的正确方法还是有更好的方法？