src/main/java/com/mapr/fuse/client/TopicWriter.java
@SuppressWarnings("SameParameterValue")
    public void writeToTopic(final String streamTopicName, final byte[] message, final Long timeout) throws InterruptedException, ExecutionException, TimeoutException {
        ProducerRecord<byte[], byte[]> rec = new ProducerRecord<>(streamTopicName, message);
        kafkaProducer.send(rec).get(timeout, TimeUnit.MILLISECONDS);
    }
/**
     * Used to write messages to a topic. If write operation is slow, It will throw timeout exception.
     *
     * @param streamTopicName stream and topic name in mapr streams format 'streamName':'topicName'
     * @param message         message to send
     * @param timeout         timeout for operation
     */
Used to write messages to a topic. If write operation is slow, It will throw timeout exception.
@param streamTopicName stream and topic name in mapr streams format 'streamName':'topicName'
@param message         message to send
@param timeout         timeout for operation
Used to write messages to a topic . If write operation is slow It will throw timeout exception . @param streamTopicName stream and topic name in mapr streams format ' streamName ' : ' topicName ' @param message message to send @param timeout timeout for operation
@SuppressWarnings("SameParameterValue")
    public void writeToTopic(final String streamTopicName, final byte[] message, final Long timeout) throws InterruptedException, ExecutionException, TimeoutException {
        ProducerRecord<byte[], byte[]> rec = new ProducerRecord<>(streamTopicName, message);
        kafkaProducer.send(rec).get(timeout, TimeUnit.MILLISECONDS);
    }
@ SuppressWarnings ( "SameParameterValue" ) public void writeToTopic ( final String streamTopicName , final byte [ ] message , final Long timeout ) throws InterruptedException , ExecutionException , TimeoutException { ProducerRecord < byte [ ] , byte [ ] > rec = new ProducerRecord < > ( streamTopicName , message ) ; kafkaProducer . send ( rec ) . get ( timeout , TimeUnit . MILLISECONDS ) ; }
Used to write messages to a topic.
Used to write messages to a topic .