...

src/main/java/cn/com/qmth/examcloud/reports/commons/util/ReportsUtil.java

@@ -36,12 +36,18 @@ public class ReportsUtil {
 	static {
 		if (reportEnable) {
 			if (MqType.KAFKA.getCode().equals(mqType)) {
+
 				Properties props = new Properties();
+
 				props.put("bootstrap.servers",
 						PropertyHolder.getString("$kafka-bootstrap-servers"));
-				props.put("key.serializer", PropertyHolder.getString("$kafka-key-serializer"));
-				props.put("value.serializer", PropertyHolder.getString("$kafka-value-serializer"));
+				props.put("key.serializer", PropertyHolder.getString("$kafka-key-serializer",
+						"org.apache.kafka.common.serialization.StringSerializer"));
+				props.put("value.serializer", PropertyHolder.getString("$kafka-value-serializer",
+						"org.apache.kafka.common.serialization.StringSerializer"));
+
 				kafkaProducer = new KafkaProducer<String, String>(props);
+
 			} else if (MqType.ROCKETMQ.getCode().equals(mqType)) {
 				// TODO
 			} else {