消息推送系统

public class MessageSender {

private KafkaProducer producer;

public MessageSender() {

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

producer = new KafkaProducer<>(props);

}

public void sendMessage(String topic, String message) {

ProducerRecord record = new ProducerRecord<>(topic, message);

producer.send(record);

}

}