kafka三个分组两个分区

Kafka是由Apache开发的一种分布式的消息系统，具有高效、可靠、可扩展等特点，可以用于数据流处理、日志收集等场景。在Kafka中，消息被组织成一个个Topic，每个Topic可以分为多个分区，每个分区在多个Broker之间进行复制以实现高可用性。

本文将从分组、分区两个方面介绍Kafka的相关概念，并提供代码示例。

一、分组

在Kafka中，消费者通过分组来进行消息的订阅和消费。同一分组中的消费者会竞争消费消息，不同分组中的消费者则互不影响。通过分组机制，Kafka可以保证消息被均衡消费，并实现消费者高可用性。

Kafka中消费者组的概念比较重要，以下是一个消费者组的示例：

@Configuration
@EnableKafka
public class KafkaConsumerConfig {

    @Value("${spring.kafka.bootstrap-servers}")
    private String bootstrapServers;

    @Value("${spring.kafka.group-id}")
    private String groupId;

    @Bean
    public ConsumerFactory<String, String> consumerFactory() {
        Map<String, Object> props = new HashMap<>();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        props.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        return new DefaultKafkaConsumerFactory<>(props);
    }

    @Bean
    public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(consumerFactory());
        return factory;
    }

    @KafkaListener(topics = "test", groupId = "group_id")
    public void listen(String message) {
        System.out.println("Received message: " + message);
    }
}

在上述代码中，@KafkaListener注解声明了一个消费者，并指定它所属的分组group_id。同时，在消费者工厂中，也要指定consumerConfig中的groupId属性。

二、分区

Kafka的分区机制可以提供消息的并行处理能力，并使得消息在Broker间可以做到负载均衡。分区的数量