kafka 0.10.2 消息生产者
2017-03-22 23:12
253 查看
package cn.xiaojf.kafka.producer; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.ProducerRecord; import java.util.Properties; /** * Created by 肖建锋 on 2017/3/22. */ public class MsgProducer2 { public static void main(String[] args) { Properties props = new Properties(); props.put("bootstrap.servers", "192.168.59.130:9092,192.168.59.131:9092,192.168.59.132:9092"); props.put("acks", "all"); props.put("retries ", 1); props.put("buffer.memory", 33554432); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); Producer<String, String> producer = new KafkaProducer(props); for(int i = 0; i < 100; i++) producer.send(new ProducerRecord<String, String>("my-replicated-topic", Integer.toString(i), Integer.toString(i))); producer.close(); } }
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.10.2.0</version> </dependency>
相关文章推荐
- kafka 0.10.2 消息生产者(producer)
- kafka 0.8.2 消息生产者 producer
- 基于Kafka的生产者消费者消息处理本地调试
- kafka单条消息过大导致生产者程序发送到broker失败
- kafka 0.8.2 消息生产者 KafkaProducer
- 使用Python开发Kafka消息生产者
- 基于Confluent.Kafka实现的KafkaConsumer消费者类和KafkaProducer消息生产者类型
- storm bolt作为kafka消息队列生产者
- 基于Kafka的生产者消费者消息处理本地调试
- kafka-clients 0.10 消息生产者
- java 实现kafka消息生产者和消费者
- kafka 0.10.2 解决java无法生产消息到指定topic问题
- 基于kafka-net实现的可以长链接的消息生产者
- kafka(java客户端)消费者取不到消息,生产者消息也没发送成功
- 实践kafka生产者消息
- 分布式消息中间件(三)——Kafka生产者消费者模型
- kafka 0.10.2 消息消费者
- 分布式消息系统kafka
- kafka消息发送和消息接受
- kafka消息中间件及java示例