如果kafka自带的序列化器不能满足我们的需求，则我们可以实现接口来自定义序列化器，下面是一个自定义类序列化器的例子：假设我们要发送的是User}我们可以自定义} }我们自定义把User对象转换为JSON字符串，然后把JSON字符串转换为字节数组返回要使用自定义的序列化器，配置即可。...

KafkaProducer还提供了一个带超时时间的重载方法，如果使用这个重载方法，则只会等待指定的超时时间，如果超过了这个时间，即使还有消息未发送完成，也会强行退出。kafka消费消息是一个不断轮询的过程，在上面的代码中可以看出，消费者消费消息就是重复的调用。就是发后即忘，他只管发送消息，至于有没有发送成功不关心，这就有消息丢失的可能。有四个重载方法，可以以集合的方式或者正则表达式的方式来订阅主题