Review Board 1.7.22


replicas may not have consistent data after becoming follower

Review Request #15938 - Created Dec. 1, 2013 and updated

Jun Rao
KAFKA-1154
Reviewers
kafka
kafka
kafka-1154; fix 1

 
core/src/main/scala/kafka/api/FetchRequest.scala
Revision fb2a2306003ac64a8a3b2fc5fc999e0be273f48d New Change
[20] 129 lines
[+20]
130
        4 /* fetch size */
130
        4 /* fetch size */
131
      )
131
      )
132
    })
132
    })
133
  }
133
  }
134

    
   
134

   
135
  def isFromFollower = replicaId != Request.OrdinaryConsumerId && replicaId != Request.DebuggingConsumerId
135
  def isFromFollower = Request.isReplicaIdFromFollower(replicaId)
136

    
   
136

   
137
  def isFromOrdinaryConsumer = replicaId == Request.OrdinaryConsumerId
137
  def isFromOrdinaryConsumer = replicaId == Request.OrdinaryConsumerId
138

    
   
138

   
139
  def isFromLowLevelConsumer = replicaId == Request.DebuggingConsumerId
139
  def isFromLowLevelConsumer = replicaId == Request.DebuggingConsumerId
140

    
   
140

   
[+20] [20] 70 lines
core/src/main/scala/kafka/api/RequestOrResponse.scala
Revision b62330be6241c8ff4acd21f0fa7e80b7636e0d42 New Change
 
core/src/main/scala/kafka/server/KafkaApis.scala
Revision 80a70f1e5e3a7670b2238fe63b8d9e0eac6b46ac New Change
 
core/src/main/scala/kafka/server/ReplicaManager.scala
Revision 54f6e1674255f62eba9d90aab0db371c82baf749 New Change
 
core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala
Revision f1f139e485d98e42be17cdcc327961420cd8c012 New Change
 
  1. core/src/main/scala/kafka/api/FetchRequest.scala: Loading...
  2. core/src/main/scala/kafka/api/RequestOrResponse.scala: Loading...
  3. core/src/main/scala/kafka/server/KafkaApis.scala: Loading...
  4. core/src/main/scala/kafka/server/ReplicaManager.scala: Loading...
  5. core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala: Loading...