Kafka的体系结构

  /** * 生产者 */ public class TestProducer { public static void main(String[] args) throws Exception { Properties props = new Properties(); props.put("bootstrap.servers", "node4:9092,node2:9092,node3:90

>>阅读原文<<