kafka---生产者

生产者发送消息的三种模式

1.发后即忘（常用）-------性能最高，可靠性最差
2.同步
3.异步

重试

        Properties props = new Properties();
        //配置kafka生产者重试次数
        props.put(ProducerConfig.RETRIES_CONFIG, 3);
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容

  • Kafka生产者——向 Kafka写入数据
    不管是把 Kafka 作为消息队列、消息、总线还是数据存储平台来使用 ，总是需要有一个可以往 Kafka 写入数据...
    消失er阅读 11,339评论 1赞 5
  • Kafka 生产者
    Kafka的版本为2.0.0、jdk 1.8.0_231、scala 2.11.8。 生产者客户端开发 必要的参数...
    一生逍遥一生阅读 720评论 0赞 1
  • Kafka生产者：写消息到Kafka
    本章我们将会讨论Kafka生产者是如何发送消息到Kafka的。Kafka项目有一个生产者客户端，我们可以通过这个客...
    zwb_jianshu阅读 485评论 0赞 0
  • Kafka生产者：写消息到Kafka
    本章我们将会讨论Kafka生产者是如何发送消息到Kafka的。Kafka项目有一个生产者客户端，我们可以通过这个客...
    printf200阅读 8,114评论 0赞 3
  • 铁陨石
    陨石(meteorite)是地球以外未燃尽的宇宙流星脱离原有运行轨道或呈碎块散落到地球或其它行星表面石质、铁质或是...
    艺术人生88阅读 396评论 1赞 0