10 | KafkaApis：Kafka最重要的源码入口，没有之一

你好，我是胡夕。我来公布上节课的“课后讨论”题答案啦～ 上节课，咱们重点了解了请求处理的全流程。课后我请你思考这样一个问题，即请求处理流程的哪些部分应用了经典的“生产者 - 消费者”模式。其实在Kafka的网路通信层，请求队列和响应队列都应用了生产者-消费者模式。请求队列的生产者是Processor线程，消费者是KafkaRequestHandler线程；响应队列的生产者是KafkaRequestHandler线程，而Processor线程是消费者。 okay，你同意这个说法吗？或者说你有其他的看法吗？我们可以一起讨论下。

个人觉得答案应该在handleOffsetCommitRequest 方法中，比较贴近的应该是这一段 // reject the request if not authorized to the group if (!authorize(request, READ, GROUP, offsetCommitRequest.data.groupId)) { val error = Errors.GROUP_AUTHORIZATION_FAILED val responseTopicList = OffsetCommitRequest.getErrorResponseTopics( offsetCommitRequest.data.topics, error) sendResponseMaybeThrottle(request, requestThrottleMs => new OffsetCommitResponse( new OffsetCommitResponseData() .setTopics(responseTopicList) .setThrottleTimeMs(requestThrottleMs) )) 如果没有授权给组，则拒绝请求

胡总，我们目前生产版本是2.1.0，遇到一个比较严重也比较紧急问题，希望您能帮忙分析一下是不是版本问题。 很奇怪的现象就是重启某个有问题的broker就正常了，但是维持不到八个小时，又出问题了。 我把jira贴一下，你帮我看下，是否有人遇到同样问题问你。看jira回答，是在2.1.1版本修复了。 https://issues.apache.org/jira/browse/KAFKA-7697 https://issues.apache.org/jira/browse/KAFKA-7870 https://issues.apache.org/jira/browse/KAFKA-6582 谢谢谢谢谢谢！

提交位移在handleOffsetCommitRequest方法中，需要判断当前发起commitRequest的Consumer对这个group是否有读权限

if (!authorize(request.context, READ, GROUP, offsetCommitRequest.data.groupId)) { 需要消费者组有读权限

有 READ权限就可以了~~

我看的kafka版本0.9中提交consumer位移在handleoffsetcommitrequest方法中，执行authorize验证在simpleaclauthorizer类map中是否包含这个用户，如果有则验证通过。

老师，你好。学习kafka很容易想到raft，理论上很多近似和相同的地方。我的问题是：在实际生产环境中，需要搭建跨地域的集群，保证一致性是不是根本就不太可行？集群随时都有可能脑裂？isr集合一直变来变去。 如果不能跨地域的话，异地多中心的数据如何保证一致性呢？