结束语 | 源码学习，我们才刚上路呢

胡老师。有个问题我实在是没有办法了，但探索欲折磨我想知道答案，还希望老师能帮帮我。关于kafka消息的有序性，我们都知道同一个分区内可以保证消息的有序性。但我百度谷歌遍了网上也找不到任何人可以解释为什么kafka能做到这一点。我从LogSegment找到Log，再到MemoryRecords到MemoryRecordsBuilder然后到RecordBatch再到RecordsAccumulator。尽管log.append和MemoryRecordsBuilder.append等方法确实加锁了。但这只能保证某一个生产者发送到单一分区的消息集合是顺序的。如果是多个producer想一个topic发送呢？不同的producer发到相同分区的数据，他们之间如何保证有序呢？这点我始终找不到确信的答案。我甚至怀疑过顺序是在消费端保证的，但消费者的poll方法根本没有机会查到任何端倪，并且这样的设计也并不高效。我也怀疑过这个顺序是否和索引有关，但索引的entry是疏松的，即并不是对每条消息都有索引记录，那不同消息集合内部的数据如果不是顺序的，索引又如何能解决呢？

一刷完结撒花🎉。 第一遍粗读我大概了解一下 Kafka 内部机制和原理，现在二刷就得自己读源码和做实验去深入理解和加深印象了。 我们开头见！

胡老师好，公司想搭kafka集群，内存和磁盘应该如何估算。谢谢！内存是看topic数量，多少个partition,相乘再相估算多少数据在内存。觉得不够明白，麻烦老师讲下，谢谢！

胡老师好，我最近在做Kafka性能测试，单块HDD盘，10Topic，10Partition，10个生产者 + 10个消费者；生产的速度会被压的很低，只有7k左右，消费速度很高；再往后50Topic ， 10Partition，生产速度会一直被挤压到2k左右，生产者出现大量超时，处于完全不可用状态。这时候磁盘使用率一直是 100% ，请问老师有没有什么办法可以给消费者限流，保证生产速度和消费速度差不多，不至于相差很悬殊，导致生产数据丢失 ？ 还有一点就是源码中没有看到优先保证消费请求的逻辑，为什么测试的时候发现，生产者消费者组相同的条件下，有堆积，都是消费速度很高，生产速度很低呢 ？ 老师有时间帮忙解惑下，万分感谢。

胡老师，以后还会有课程吗？期待～

胡老师您好，感谢您的课程，我到了很多。请问是否有机会再开一门课程讲讲connect，谢谢老师。

感谢，老师的kafka水平令我折服

老师，请教一个问题 2021-12-09 20:43:46,031 WARN org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase [] - Consumer subtask 5 failed async Kafka commit. org.apache.kafka.clients.consumer.RetriableCommitFailedException: Offset commit failed with a retriable exception. You should retry committing the latest consumed offsets. Caused by: org.apache.kafka.common.errors.CoordinatorNotAvailableException: The coordinator is not available. 这个是什么问题 我发现fkink消费kafka，某些分区突然提交不上去offset了

👍感谢～