??????????partitionOffset ??????????????offset FlinkKafkaConsumer011 consumer = ... Map<KafkaTopicPartition, Long> partitionOffset = ... consumer.setStartFromSpecificOffsets(partitionOffset);
------------------ ???????? ------------------ ??????: "Biao Liu"<[email protected]>; ????????: 2019??3??20??(??????) ????3:24 ??????: "user-zh"<[email protected]>; ????: Re: FlinkKafkaConsumer ???????????????????????? Hi, ???????????? topics, topicPattern ???????????????????? yuqingshui <[email protected]> ??2019??3??18?????? ????10:33?????? > ??????FlinkKafkaConsumer ??????????????????????????
