/
[Apache-SVN]
Revision 1397422
Jump to revision:
Author:
nehanarkhede
Date:
Fri Oct 12 02:56:28 2012 UTC
(12 years, 1 month ago)
Changed paths:
17
Log Message:
KAFKA-432 allow consumer to read from followers; patched by Yang Ye; reviewed by Neha and Jun
Changed paths
Path
Details
incubator/kafka/branches/0.8/bin/kafka-consumer-shell.sh
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchRequest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/OffsetRequest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/RequestOrResponse.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/cluster/Replica.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/ReplicaNotAvailableException.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerFetcherThread.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/SimpleConsumer.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/OffsetRequest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaApis.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaManager.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ConsumerShell.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/DumpLogSegments.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/SimpleConsumerShell.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala
modified
,
text changed
infrastructure at apache.org
ViewVC Help
Powered by
ViewVC 1.1.26