Bir monolit tətbiqi ilə Kafka arasında mesaj mübadiləsi həyata keçirmək mümkündürmü?

Bəli, monolit tətbiqi ilə Kafka arasında mesaj mübadiləsi tamamilə mümkündür. Bunun üçün Java layihəsində Kafka müştəri kitabxanasından istifadə etmək olar (məsələn, Apache Kafka Clients). Monolit tətbiqi mesajların istehsalçısı və/və ya istehlakçısı kimi fəaliyyət göstərir.

Java-da sadə mesaj istehsalçısının nümunəsi:

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();

Beləliklə, hətta monolit tətbiqdə belə Kafka ilə inteqrasiya etmək mümkündür və bu, mesajların asinxron mübadiləsini təmin edir, sistemin genişlənəbilərliyini və etibarlılığını artırır.