面试官:听说你精通Kafka,那我就考考你吧 面试官:不用慌尽管说,错了也没关系😊。。。 面试官:你先说说Kafka由什么模块组成吧 嗯嗯好的。 主要有:生产者、消费者、Brocker、Topic、消息分区Partition。 面试官思考中… 面试官:那我们先讲讲生产者、消费者? 嗯嗯好的。 面试官思考中… 面试官:消息生产者的异步回调,知道吧 Ok知道的。主要是可以进行异常日志的记录。 是这样的,Kafka的异步提交消息相比同步提交,不需要在brocker响应前阻塞线程。 但是异步提交我们是不知道消费情况的,所以就可以在Kafka消费异常时,通过其回调来告知程序异常情况...