消息推送系统

// 创建Kafka生产者实例

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 producer = new KafkaProducer<>(props);

// 发送消息

ProducerRecord record = new ProducerRecord<>("university-topic", "student-id-123", "Notification Message");

producer.send(record);

producer.close();

]]>