2019-09-12我们需要一些速成的实战经验，比如消息队列突然延迟2个小时该如何解决？
希望带着这些类似的问题，结合设计原理，帮助我们层层解析。。。 16
2019-09-17offset的提交不知道是不是在kafkaConsumer.commitAsync中调用coordinator.commitOffsetsAsync(offsets,callback)
1、这里设计成异步方式一开始我是比较奇怪的，他是如何保证offset不丢失呢？看了代码才知道在异步返回前会等待ConcurrentLinkQueue<offsetCommitCompletetion>中没有其他的待处理的其他的offset的commit后，才会返回，这里的非阻塞队列是线程安全的，可以避免当前提交冲掉其他的offset的提交
2、真正进行提交的时候也不是调用什么具体操作net的接口，而是向另一个ConcurrentLinkedQueue中注册了一个RequestFutureListener的监听者，当然注册之前使用了AtomicInteger来保证并发安全。
3、每个监听者应该都会由相应的Coordinator轮询处理队列中的待提交请求，将offset提交从具体的Consumer中解耦到每个组的Coordinator中。
当然以上只是个人理解，如有不当欢迎指正。
读完这个代码，我发现kafka在这里保证并发数据一致性时，使用了安全的数据结构+CAS的数据访问，灵活且大大降低了锁机制的粗粒度带来的性能损耗，只是这个代码真不容易写好，真是大牛作品！！展开 2- 2019-09-13消费者如何从服务端拉取消息的，用for循环效率太低吧，能否说说实际的代码
作者回复: 同学，我们这节课通篇就是讲得这个问题啊，给你们讲解使用的就是实际的代码。
2 1 
2019-09-12先打卡：代码慢慢研究；老师今天讲述了研究代码的目的：
1.消息队列实现的主要流程都一样，掌握流程的实现过程；遇到收发消息的问题，都可以用同样的思路去分析和解决问题。
2.看一下源代码，理清消费生产的实现过程，从中学习一些优秀的设计思路和编码技巧。
这个算是一个小的总结吧：明天中秋休息刚好可以啃代码，好好研究代码去体会。
明天是中秋佳节：愿老师节日快乐^_^ 1
2019-11-17当 Partition 或是 Consumer 发生变更是，会触发 reblance（重新分配）过程。
这句话有两个错别字。。。作者回复: 我联系编辑同学修改，感谢！
2019-11-01课后作业，希望老师指正。
在基础篇03的时候讲过消费位置是消息队列服务器针对每个消费组和每个队列维护的一个位置变量。那么也就是说最终真正更新这个位置变量应该是交由服务器去执行的，而Consumer只是发送一个请求。那么顺着这个思路，我猜应该是在更新元数据的时候就应该发送这个请求，原因很简单：消费者需要知道“从哪发起”并且“发多少”，因此这时就已经知道了应该将消费位置更新为多少了，所以这时候就可以发送这个请求了。至于服务器最终会将消费位置更新为多少，还取决于客户端返回的结果。
在方法updateAssignmentMetadataIfNeeded中，最后一行return updateFetchPositions(timer);
从updateFetchPositions这个方法点进去，看到coordinator.refreshCommittedOffsetsIfNeeded(timer)
这个方法点进去之后会看到fetchCommittedOffsets方法，进这个方法，找到sendOffsetFetchRequest，点进去，最终会发现 client.send(coordinator, requestBuilder)展开作者回复: 细致👍
2019-10-20上一节课我和你一起通过分析源代码学习了 RocketMQ 消息生产的实现过程，本节课我们来看一下 Kafka 消费者的源代码，理清 Kafka 消费的实现过程，并且能从中学习到一些 Kafka 的优秀设计思路和编码技巧。
老师，为什么上一讲是Rabbit这一讲是kafka?作者回复: 因为我们这个课需要照顾到使用不同消息队列和使用不同语言的小伙伴啊。
2019-10-10这篇文章真的好深，看了好几遍才明白，异步的设计好复杂，现在明白前面为什么老师讲那些基础了- 2019-09-30老师，你好，broker和消费端都重启了，消费端还知道从哪个offset开始消费吗
作者回复: 从服务端的协调者获取。服务端的协调者会记录主题的每个消费组的每个分区当前的消费位置
2 - 2019-09-30消费端重启的时候，他会从哪里拿offset呢？他是从头还是拿消息还是从上次消费的地方？这个offset能讲讲吗？
- 2019-09-25老师，主题和分区，以及分区和ConsumerGroup到底是几对几的关系
- 2019-09-25ConsumerGroup，和分区什么关系，有多少个ConsumerGroup呢
2019-09-21老师好，看了Rocketmq consumer源码，为啥启动consumer实例的时候也会初始化producer，是为了提交消费位点吗？作者回复: 你能说一下在代码中哪个地方初始化了Producer吗？
2
2019-09-15用代码跟类图来讲解一个系统的实现还是太过于抽象，难以把握住，最好的方式是用老师理解的东西然后转换成通俗易懂的原理图来讲解作者回复: 我还是希望同学们能通过学习，具备独立分析代码，独立设计能力，这样才能提高。
2019-09-12老师好，先祝您节日快乐！！！您辛苦了~
有几个疑问需要老师解答一下：
①今天在看rocketMq源码过程中，发现DefaultMQProducer有个属性defaultTopicQueueNums，它是用来设置topic的ConsumeQueue的数量的吗？我之前的理解是，consumeQueue的数量是创建topic的时候指定的，跟producer没有关系，那这个参数又有什么作用呢？
②在RocketMq的控制台上可以创建topic，需要指定writeQueueNums，readQueueNums，perm，这三个参数是有什么用呢？这里为什么要区分写队列跟读队列呢？不应该只有一个consumeQueue吗？
③用户请求-->异步处理--->用户收到响应结果。异步处理的作用是：用更少的线程来接收更多的用户请求，然后异步处理业务逻辑。老师，异步处理完后，如何将结果通知给原先的用户呢？即使有回调接口，我理解也是给用户发个短信之类的处理，那结果怎么返回到定位到用户，并返回之前请求的页面上呢？需要让之前的请求线程阻塞吗？那也无法达到【用更少的线程来接收更多的用户请求】的目的丫。
望老师能指点迷津~~~展开 1