diff --git a/src/com/zdemo/Event.java b/src/com/zdemo/Event.java index af1f4d3..cffb45d 100644 --- a/src/com/zdemo/Event.java +++ b/src/com/zdemo/Event.java @@ -1,10 +1,24 @@ package com.zdemo; +/** + * 发布订阅 事件 + * + * @param + */ public class Event { private String topic; private String key; private V value; + public Event() { + } + + public Event(String topic, String key, V value) { + this.topic = topic; + this.key = key; + this.value = value; + } + public String getTopic() { return topic; } diff --git a/src/com/zdemo/kafak/KafakProducer.java b/src/com/zdemo/kafak/KafakProducer.java index 6176a52..43f45cc 100644 --- a/src/com/zdemo/kafak/KafakProducer.java +++ b/src/com/zdemo/kafak/KafakProducer.java @@ -30,7 +30,13 @@ public class KafakProducer implements IProducer, Service { @Override public void init(AnyValue config) { - try (FileInputStream fis = new FileInputStream(new File(APP_HOME, "conf/kafak.properties"));) { + File file = new File(APP_HOME, "conf/kafak.properties"); + if (!file.exists()) { + logger.warning(String.format("------\n%s (系统找不到指定的文件。)\n未初始化kafak 生产者,kafak发布消息不可用\n------", file.getPath())); + return; + } + + try (FileInputStream fis = new FileInputStream(file)) { Properties props = new Properties(); props.load(fis); producer = new KafkaProducer(props);