KafkaRoundRobinpartitioner未将消息分配到4个分区中。

Kafka默认使用RoundRobin partitioner将消息分配到分区中。如果您的应用程序需要使用四个或更多的分区，并且消息未正确分配，则可能是由于在创建生产者时默认分区数设置不正确所致。你可以在生产者中设置分区数来解决这个问题，例如：

Properties props = new Properties();
props.put("bootstrap.servers", "your_broker_host:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("acks", "all");
props.put("retries", 0);
props.put("batch.size", 16384);
props.put("linger.ms", 1);
props.put("buffer.memory", 33554432);
props.put("partitioner.class", "org.apache.kafka.clients.producer.internals.RoundRobinPartitioner");
props.put("partitioner.num.partitions", 4); //设置4个分区
Producer<String, String> producer = new KafkaProducer<>(props);

请确保将partitioner.num.partitions设置为正确的分区数，以解决消息未分配到正确分区的问题。