Kafka简介 Kafka是一个由Scala和Java编写的企业级的消息发布和订阅系统,最早是由Linkedin公司开发,最终开源到Apache软件基金会的项目。Kafk...
生产者客户端:主线程和 Sender 线程 1、主线程:由 KafkaProducer 创建消息,通过拦截器、序列化器和分区器后缓存到消息累加器(RecordAccumula...
前言 使用 insert into on duplicate key update 语句进行插入去重,但是在测试过程中发现了死锁现象: 表锁和行锁 首先来了解一下表锁和行锁:...