subsys/kafka/src/main/java/org/commonjava/indy/subsys/kafka/IndyKafkaProducer.java
public void send( String topic, String message, LogbackFormatter formatter, long timeoutMillis )
                    throws IOException, InterruptedException, ExecutionException, TimeoutException
    {
        Future future = doKafkaSend( topic, message, formatter );
        if ( future != null )
        {
            future.get( timeoutMillis, TimeUnit.MILLISECONDS );
        }
    }
public void send( String topic, String message, LogbackFormatter formatter, long timeoutMillis )
                    throws IOException, InterruptedException, ExecutionException, TimeoutException
    {
        Future future = doKafkaSend( topic, message, formatter );
        if ( future != null )
        {
            future.get( timeoutMillis, TimeUnit.MILLISECONDS );
        }
    }
Blocking send with a logback formatter to format the message.