kafka消息发到哪个分区

Kafka是一个高性能、高可靠性、分布式消息系统，其重要特性之一就是良好的消息分区机制。在Kafka中，消息通过Producer发送到Broker，然后由Broker存储和分发到相应的Consumer。但是，如何决定将消息发到哪个分区呢？

Kafka的分区机制是基于哈希值的。这个哈希值默认是由消息的key计算得到的，如果key为空，则采用随机方式分配到一个分区。下面，我们来看一下Kafka中消息是如何计算分区的。

首先，在Kafka中，分区是一组有序的、不可变的消息序列。Broker会为每个Topic创建若干个Partition，每个Partition中的消息都是有序的、可复制的，并且只会在该Partition所在的机器上进行读写。如下图所示：

当Producer发送消息时，Kafka会根据消息的key进行哈希运算，得到一个哈希值。然后，将哈希值对Partition数量取模，得到一个分区编号。如果该分区存在，则将消息存储到该分区中；否则，创建该分区并将消息存储到该分区中。

简单说来，可以使用以下代码示例：

import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.common.serialization.StringSerializer;

import java.util.Properties;

public class ProducerDemo {
    public static void main(String[] args) {
        String bootstrapServers = "localhost:9092";
        String topic = "my-topic";

        //设置Producer的配置属性
        Properties properties = new Properties();
        properties.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        properties.setProperty(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
        properties.setProperty(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());

        //创建Producer
        KafkaProducer<String, String> producer = new KafkaProducer<String, String>(properties);

        //发送消息
        String key = "my-key";
        String value = "hello world";
        ProducerRecord<String, String> record = new ProducerRecord<String, String>(topic, key, value);
        producer.send(record);

        //关闭Producer
        producer.close();
    }
}

这段