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 );
        }
    }
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.
Blocking send with a logback formatter to format the message .