Kafka源码分析--生产者

ps.本文所有源码都基于kafka-0.10.0.1 Kafka提供了Java版本的生产者实现--KafkaProducer，使用KafkaProducer的API可以轻松实现同步／异步发送消息、批量发送、超时重发等复杂的功能，KafkaProducer是线程安全的，多个线程之间可以共享实用同一个KafkaProducer对象。 下面先看一个使用上的小例子： public static void

>>阅读原文<<