In Kafka, you can assign the partitions using KafkaConsumer.assign:

KafkaConsumer<String, String> consumer=new KafkaConsumer<>(prop);consumer.assign(partitions);

Is there a way to do the same for the FlinkKafkaConsumer010 or to get a handle on the KafkaConsumer?

share|improve this question

    Your Answer

     
    discard

    By posting your answer, you agree to the privacy policy and terms of service.

    Browse other questions tagged or ask your own question.