Kafka生产者/消费者是否占用主题中的一个分区？

Kafka的生产者和消费者默认情况下会使用主题中所有可用的分区，而不是仅限于一个分区。可以使用指定的分区ID或使用分区键来发送消息到特定的分区。示例代码如下：

//创建生产者 Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); KafkaProducer<String, String> producer = new KafkaProducer<>(props);

//发送消息到特定分区 ProducerRecord<String, String> record = new ProducerRecord<>("my_topic", 1, "key", "value"); producer.send(record);

//创建消费者 Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("group.id", "my_group"); props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

//订阅特定的分区 TopicPartition partition = new TopicPartition("my_topic", 1); consumer.assign(Collections.singletonList(partition));