<h1>

    topic replication 同步失败 急！！<br />

</h1>

<p>

    <br />

</p>

<p>

    问题：一个topic有3个副本，但是副本直接同步失败，只有一个broker 可用

</p>

<p>

    在broker1 和broker2 上查看controler 日志发现错误日志：

</p>

<p>

<pre class="brush :">[2016-05-16 13:44:41,617] INFO [SessionExpirationListener on 0], ZK expired; shut down all controller components and try to re-elect (kafka.controller.KafkaController$SessionExpirationListener)</pre>

</p>

<p>

    查看server.log 日志：

</p>

<pre class="brush :"> PartitionFetchInfo(23122,104857400). Possible cause: java.io.EOFException: Received -1 when reading from channel, socket has likely been closed. (kafka.server.ReplicaFetcherThread)

​

[2016-05-16 13:45:07,118] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions  (kafka.server.ReplicaFetcherManager)

[2016-05-16 13:45:07,129] INFO [ReplicaFetcherManager on broker 0] Added fetcher for partitions List() (kafka.server.ReplicaFetcherManager)</pre>

<p>

    broker3 的日志“：server.log

</p>

<p>

<pre class="brush :">kafka.common.KafkaException: This operation cannot be completed on a complete request.

        at kafka.network.Transmission$class.expectIncomplete(Transmission.scala:34)

        at kafka.api.TopicDataSend.expectIncomplete(FetchResponse.scala:102)

        at kafka.api.TopicDataSend.writeTo(FetchResponse.scala:120)

        at kafka.network.MultiSend.writeTo(Transmission.scala:101)

        at kafka.api.FetchResponseSend.writeTo(FetchResponse.scala:231)

        at kafka.network.Processor.write(SocketServer.scala:472)

        at kafka.network.Processor.run(SocketServer.scala:342)

        at java.lang.Thread.run(Thread.java:745)</pre>

</p>

<p>

    <br />

</p>