kafkaProducer在启动的时候，就将sender封装到KafkaThread类里面，作为daemon进程启动了
String ioThreadName = "kafka-producer-network-thread" + (clientId.length() > 0 ? " | " + clientId : "");
this.ioThread = new KafkaThread(ioThreadName, this.sender, true);
this.ioThread.start();
绍圣--kafka之生产者（三）话说上回中，KafkaProducer已经将生产的记录追加到了RecordAccumulator中。那么接下来的事情，就是怎么样把这些记录提交到服务端了。 是否还记得在Kaf...
写的很详细。我在debug kafkaProducer源码的时候，到了sender.wakeup();这里，但是进不去这个sender的run方法。所以接下来sender类的操作，我跟踪不下去了。
绍圣--kafka之生产者（三）话说上回中，KafkaProducer已经将生产的记录追加到了RecordAccumulator中。那么接下来的事情，就是怎么样把这些记录提交到服务端了。 是否还记得在Kaf...
话说上回中，KafkaProducer已经将生产的记录追加到了RecordAccumulator中。那么接下来的事情，就是怎么样把这些记录提交到服务端了。 是否还记得在Kaf...
上一节我们介绍了kafka涉及到的相关概念，大家对kafka服务的基本结构也有了初步的印象。这一节里我们要做的，就是动手将上一节的kafka服务结构部署到我们的机器上，搭建k...
网上关于Apache Kafka的介绍已经有很多了，因此我不打算在这里对它的概念做过多的描述，更多的是从应用场景的角度来切入我们的Kafka学习之旅。 还记得我当初在做一个分...
一、前言 第一期的时候原本是为了好玩，加上我之前是在某公司管理着十几个人的技术团队，而现在出来帮朋友做一个小项目，只有自己可以管理。然而我这个人吧，非常害怕自己不能成长，技术...
