public void send ( String topic , String message , long timeoutMillis ) throws IOException , InterruptedException , ExecutionException , TimeoutException { send ( topic , message , null , timeoutMillis ) ; }
Blocking send . The message will be available to consumers immediately . Wait for at most the given time for the operation to complete .