使用Nginx做反向代理时，当被代理服务器没有在指定时间内创建连接、接受请求或返回响应时，Nginx就会断开连接，并返回给客户端“504 Gateway Time-out”错误。关于Nginx做反向代理超时，可以通过proxy_connect_timeout、proxy_send_timeout和proxy_read_timeout配置解决。Nginx中默认设置都是60s。三种配置描述...

Topic和Partition从概念上讲，topic只是一个逻辑概念，代表了一类消息，也可以认为是消息被发送到的地方。通常可以使用topic来区分实际业务。Kafka中的topic通常会被多个消费者订阅，因此出于性能考虑，kafka并不是topic-meaaage的两极结构，而是采用了topic-partition-message的三级结构来分散负载。从本质上说，每个kafka的topic...

__consumer_offsets是kafka自行创建的，和普通的topic相同。它存在的目的之一就是保存consumer提交的位移。__consumer_offsets的每条消息格式大致如图所示：配图105，图5.5可以想象成一个KV格式的消息，key就是一个三元组：group.id+topic+分区号，而value就是offset的值。考虑到一个kafka生成环境中可能有很多...

通过kafka-consumer-groups.sh 脚本查看或变更消费组的信息。消费组一共有 Dead 、Empty 、PreparingRebalance 、CompletingRebalance 、Stable 这几种状态，正常情况下， 一个具有消费者成员的消费组的状态为Stable 。可以通过 state 参数来查看消费组当前的状态， 示例如下：./kafka-consumer-group