kafka客户端消费消息出现这种以下情况，

2018-10-19 12:23:13.454 [Thread-13] DEBUG org.apache.kafka.clients.NetworkClient - Node -1 disconnected.
2018-10-19 12:23:13.455 [Thread-13] WARN  org.apache.kafka.clients.NetworkClient - Bootstrap broker 120.77.254.103:3811 disconnected
2018-10-19 12:23:13.455 [Thread-13] DEBUG o.a.k.c.consumer.internals.ConsumerNetworkClient - Cancelled GROUP_COORDINATOR request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@4a09c1dd, request=RequestSend(header={api_key=10,api_version=0,correlation_id=0,client_id=consumer-1}, body={group_id=}), createdTimeMs=1539922993332, sendTimeMs=1539922993441) with correlation id 0 due to node -1 being disconnected
2018-10-19 12:23:13.456 [Thread-13] DEBUG org.apache.kafka.clients.NetworkClient - Give up sending metadata request since no node is available
2018-10-19 12:23:13.556 [Thread-13] DEBUG org.apache.kafka.clients.NetworkClient - Initialize connection to node -1 for sending metadata request
2018-10-19 12:23:13.556 [Thread-13] DEBUG org.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at 120.77.254.103:3811.
2018-10-19 12:23:14.970 [Thread-13] DEBUG org.apache.kafka.common.network.Selector - Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1
2018-10-19 12:23:14.970 [Thread-13] DEBUG org.apache.kafka.clients.NetworkClient - Completed connection to node -1
2018-10-19 12:23:15.067 [Thread-13] DEBUG org.apache.kafka.clients.NetworkClient - Sending metadata request {topics=[trade-topic]} to node -1
2018-10-19 12:23:15.075 [Thread-13] DEBUG org.apache.kafka.common.network.Selector - Connection with /120.77.254.103 disconnected
java.io.EOFException: null
    at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83)
    at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71)
    at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:154)
    at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:135)
    at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:343)
    at org.apache.kafka.common.network.Selector.poll(Selector.java:291)
    at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260)
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:232)
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:209)
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:148)
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:136)
    at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:197)
    at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.fetchCommittedOffsets(ConsumerCoordinator.java:387)
    at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.refreshCommittedOffsetsIfNeeded(ConsumerCoordinator.java:369)
    at org.apache.kafka.clients.consumer.KafkaConsumer.updateFetchPositions(KafkaConsumer.java:1531)
    at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1018)
    at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:979)
    at com.exchange.message.job.ConsumerListener.run(ConsumerListener.java:26)
    at java.lang.Thread.run(Thread.java:748)