当前位置:   article > 正文

kafka 指定partition 发送数据 和指定partition 消费数据 以及 从指定的offset 开始消费数据_kafka生产者指定partition发送数据

kafka生产者指定partition发送数据

1、向指定的partition 发送数据:

        ProducerRecord record =  new ProducerRecord<String ,User>(topic,partition,key,message);

2.从指定的partition开始消费数据:

       consummer.assgin(Arrays.asList(new TopicPartition(topic,0)));

       consummer.poll(1000);

3从指定的partition的指定的offset开始消费数据:

       KafkaConsummer consummer.subscribe(Arrays.asList(topic));

      ConsummerRecords<String,User> records =  consummer.poll(1000);

      consummer.seek(new TopicPartition(topic,partitionNum),offset);

 

     consummer.commitSync(); // 向ZK提交offset

 

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/空白诗007/article/detail/794035
推荐阅读
相关标签
  

闽ICP备14008679号