public class MsgProducer { 2 public static void main ( String [] args ) throws InterruptedException , ExecutionException { 3 Properties props = new Properties (); 4 props . put ( ProducerConfig . BOOTSTRAP_SERVERS_CONFIG , "192.168.0.60:9092,192....
JAVA 网络投稿 1645