org.apache.kafka.common.serialization.StringSerializer

反正我这样写报了异常出来，org.apache.kafka.common.serialization.StringDeserializer is not an instance
下面的两行代码我运行会报错

properties.setProperty("key.serializer", StringDeserializer.class.getName());

properties.setProperty("value.serializer", StringDeserializer.class.getName());

于是我换了一个写法就可以了

KafkaProducer<String, String> producer = new KafkaProducer<String,String>(properties, new StringSerializer(), new StringSerializer());

谢谢观看！