public void send()

in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java [115:123]

• 9 lines of code
• 2 McCabe index (conditional complexity)

    public void send(String topic, Message message) {
        ProducerRecord<String, byte[]> record = new ProducerRecord<String, byte[]>(topic, PARTITION, null, message.getPayload(), toHeaders(message.getProperties()));
        try {
            RecordMetadata metadata = kafkaProducer().send(record).get();
            LOG.info(format("Sent to %s", metadata));
        } catch (InterruptedException | ExecutionException e) {
            throw new RuntimeException(format("Failed to send mesage on topic %s", topic), e);
        }
    }