Kas on võimalik teostada sõnumite vahetamine monoliitse rakenduse ja Kafka vahel?

Jā, komunikācija starp monolītisko lietotni un Kafka ir pilnīgi iespējama. Tam Java projektā var izmantot Kafka klienta bibliotēku (piemēram, Apache Kafka Clients). Monolītā lietotne darbojas kā ražotājs un/vai patērētājs ziņojumiem.

Piemērs vienkāršam ziņojumu ražotājam Java:

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import java.util.Properties;

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

KafkaProducer<String, String> producer = new KafkaProducer<>(props);
producer.send(new ProducerRecord<>("topicName", "key", "message"));
producer.close();

Tādējādi, pat monolītiskā lietotnē, ir iespējams integrēt Kafka, lai nodrošinātu asīnhronu ziņojumu apmaiņu, kas uzlabos sistēmas mērogojamību un uzticamību.