在kafka中，您可以使用kafkaconsumer.assign分配分区：
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(prop);
consumer.assign(partitions);
是否有一种方法可以为Flinkkafkaconsumer010做同样的方法或在Kafkaconsumer上获得柄？
简短的答案是否。Flinkkafkaconsumerbase(及其混凝土孩子(的Kafkafetcher领域是私人的。然后，Kafkaconsumer本身就被进一步埋葬在Fetcher内。
话虽如此，我个人还没有找到使我退缩的情况。出于好奇，为什么要访问基础消费者？