private ProducerRecord getProducerRecord()

in rcomp-kafka/src/main/java/org/apache/karaf/rcomp/kafka/KafkaDestination.java [71:81]

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

    private ProducerRecord<?, ?> getProducerRecord(T payload) {
        ProducerRecord<?, ?> record;
        if (payload instanceof ProducerRecord<?, ?>) {
            record = (ProducerRecord<?, ?>)payload;
        } else {
            // @TODO better way to determine key
            String key = "dummykey";
            record = new ProducerRecord<>(topic, key, payload);                
        }
        return record;
    }