linux 中kafka消费者指定topic分区

可以使用Kafka提供的assign()方法，手动为消费者指定要读取的分区。例如：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "test-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", 0);
consumer.assign(Arrays.asList(partition));

这样就会将消费者指定为读取名为"my-topic"的第一个分区。如果要读取多个分区，可以在assign()方法中传入多个TopicPartition对象。