1，何时创建
    A ：消费者和生产者不同，在创建KafkaConsumer实例时不会创建任何TCP连接。
        原因：是因为生产者入口类KafkaProducer在构建实例时，会在后台启动一个Sender线程，这个线程是负责Socket连接创建的。

    B ：TCP连接是在调用KafkaConsumer.poll方法时被创建。在poll方法内部有3个时机创建TCP连接
    （1）发起findCoordinator请求时创建
        Coordinator（协调者）消费者端主键，驻留在Broker端的内存中，负责消费者组的组成员管理和各个消费者的位移提交管理。
        当消费者程序首次启动调用poll方法时，它需要向Kafka集群发送一个名为FindCoordinator的请求，确认哪个Broker是管理它的协调者。

    （2）连接协调者时
        Broker处理了消费者发来的FindCoordinator请求后，返回响应显式的告诉消费者哪个Broker是真正的协调者。
        当消费者知晓真正的协调者后，会创建连向该Broker的socket连接。
        只有成功连入协调者，协调者才能开启正常的组协调操作。

    （3）消费数据时
        消费者会为每个要消费的分区创建与该分区领导者副本所在的Broker连接的TCP.

2 创建多少
    消费者程序会创建3类TCP连接：
    （1） ：确定协调者和获取集群元数据
    （2）：连接协调者，令其执行组成员管理操作
    （3） ：执行实际的消息获取

3 何时关闭TCP连接
    A ：和生产者相似，消费者关闭Socket也分为主动关闭和Kafka自动关闭。
    B ：主动关闭指通过KafkaConsumer.close()方法，或者执行kill命令，显示地调用消费者API的方法去关闭消费者。
    C ：自动关闭指消费者端参数connection.max.idle.ms控制的，默认为9分钟，即如果某个socket连接上连续9分钟都没有任何请求通过，那么消费者会强行杀死这个连接。
    D ：若消费者程序中使用了循环的方式来调用poll方法消息消息，以上的请求都会被定期的发送到Broker，所以这些socket连接上总是能保证有请求在发送，从而实现“长连接”的效果。
    E ：当第三类TCP连接成功创建后，消费者程序就会废弃第一类TCP连接，之后在定期请求元数据时，会改为使用第三类TCP连接。对于一个运行了一段时间的消费者程序来讲，只会有后面两种的TCP连接。

总共创建4个连接，最终保持3个连接：
        确定消费者所属的消费组对应的GroupCoordinator和获取集群的metadata时创建一个TCP连接，由于此时的node id = -1，所以该连接无法重用。
        连接GroupCoordinator时，创建第二个TCP连接，node id值为Integer.MAX_VALUE-id
        消费者会与每个分区的leader创建一个TCP连接来消费数据，node id为broker.id，由于kafka只是用id这一维度来表征Socket连接信息，因此如果多个分区的leader在同一个broker上时，会共用一个TCP连接，由于分区数大于broker的数量，所以会创建两个TCP连接消费数据。