如何在Kafka中同时实现分布式处理和高可用性？

I have a topic consisting of n partitions. To have distributed processing I create two processes running on different machines. They subscribe to the topic with same groupd id and allocate n/2 threads, each of which processes single stream(n/2 partitions per process). I have a topic consisting of n partitions. To h