高性能消息系统——Kafka
高性能消息系统——Kafka
什么是Kafka?
“” 官网:https://kafka.apache.org它与传统的mq区别?
- 模式
基本交互原理
默认路径/brokers/topics/<topic_id>/partitions/<partition_index>/state基本CLI操作
Properties p = new Properties(); props.put("metadata.broker.list", "10.1.110.21:9092"); ProducerConfig config = new ProducerConfig(props); Producer producer = new Producer<String, byte[]>(config); producer.send(byte[] msg);
更具体的参见:https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Example
评论暂时关闭