ps.本文所有源码都基于kafka-0.10.0.1
Kafka提供了Java版本的生产者实现--KafkaProducer，使用KafkaProducer的API可以轻松实现同步／异步发送消息、批量发送、超时重发等复杂的功能，KafkaProducer是线程安全的，多个线程之间可以共享实用同一个KafkaProducer对象。Kafka提供了Java版本的生产者
阅读背景：
Kafka源码分析--生产者
来源：互联网
分享到：
