@Test public void testSyncSend() throws ExecutionException, InterruptedException { for (int i = 0; i < 10; i++) { int id = (int) (System.currentTimeMillis() / 1000); SendResult result = producer.syncSend(id); } new CountDownLatch(1).await(); }
public SendResult syncSend(Integer id) throws ExecutionException, InterruptedException { Demo06Message message = new Demo06Message(); message.setId(id); return kafkaTemplate.send(Demo06Message.TOPIC, message).get(); }
Demo06Producer { public SendResult syncSend(Integer id) throws ExecutionException, InterruptedException { Demo06Message message = new Demo06Message(); message.setId(id); return kafkaTemplate.send(Demo06Message.TOPIC, message).get(); } }
Demo06Producer { public SendResult syncSend(Integer id) throws ExecutionException, InterruptedException { Demo06Message message = new Demo06Message(); message.setId(id); return kafkaTemplate.send(Demo06Message.TOPIC, message).get(); }  }
Demo06Producer { public SendResult syncSend(Integer id) throws ExecutionException, InterruptedException { Demo06Message message = new Demo06Message(); message.setId(id); return kafkaTemplate.send(Demo06Message.TOPIC, message).get(); }  SendResult syncSend(Integer id); SendResult syncSendOrderly(Integer id); }
Demo06Producer { public SendResult syncSend(Integer id) throws ExecutionException, InterruptedException { Demo06Message message = new Demo06Message(); message.setId(id); return kafkaTemplate.send(Demo06Message.TOPIC, message).get(); }  SendResult syncSend(Integer id); SendResult syncSendOrderly(Integer id);  }