Ar įmanoma įgyvendinti žinučių keitimą tarp monolitinės programos ir Kafka?

Taip, komunikacija tarp monolitinės programos ir Kafka yra visiškai įmanoma. Tam Java projekte galima naudoti Kafka kliento biblioteką (pavyzdžiui, Apache Kafka Clients). Monolitinė programa veikia kaip pradedantysis ir/arba vartotojas.

Pavyzdys paprasto pradedančiojo 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();

Taip pat, net ir monolitinėje programoje galima integruoti Kafka, kad būtų galima naudoti asinchroninį žinučių mainus, kas pagerins sistemos mastelį ir patikimumą.