kafka消费指定partition

在 Kafka 中，要消费指定的 partition，可以使用 Consumer API 中的 `assign()` 方法，该方法允许您分配特定的 partition。

例如，假设您要消费 topic 为 "my-topic" 的第 0 个 partition，您可以使用以下代码：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "test-group");

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

TopicPartition partition = new TopicPartition("my-topic", 0);
consumer.assign(Arrays.asList(partition));

while (true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
    for (ConsumerRecord<String, String> record : records) {
        System.out.println(record.value());
    }
}

在此示例中，我们使用 `assign()` 方法将 `my-topic` 的第 0 个 partition 分配给消费者，并使用 `poll()` 方法获取消息。请注意，在使用 `assign()` 方法时，您不需要指定 `group.id` 属性。