subsys/kafka/src/main/java/org/commonjava/indy/subsys/kafka/IndyKafkaProducer.java
public void send( String topic, String message, long timeoutMillis )
                    throws IOException, InterruptedException, ExecutionException, TimeoutException
    {
        send( topic, message, null, timeoutMillis );
    }
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.