/[Apache-SVN]
ViewVC logotype

Revision 1391168

Jump to revision: Previous Next
Author: jjkoshy
Date: Thu Sep 27 19:20:08 2012 UTC (12 years, 1 month ago)
Changed paths: 26
Log Message: 
getOffset Api should return different latest offset to non-follower and follower consumers. Also, implement a batched version of the getOffset Api. patched by Joel Koshy; reviewed by Jun Rao; KAFKA-501

Changed paths

Path Details
Directoryincubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchRequest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/api/OffsetRequest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/api/OffsetResponse.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/api/ProducerResponse.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/api/RequestOrResponse.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerFetcherThread.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/SimpleConsumer.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/Implicits.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/OffsetRequest.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/OffsetResponse.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/consumer/SimpleConsumer.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/log/Log.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/log/LogManager.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaApis.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/GetOffsetShell.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/UpdateOffsetsInZK.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/UpdateOffsetsInZK.scala deleted
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/Utils.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/LogOffsetTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/network/RpcDataSerializationTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/perf/src/main/scala/kafka/perf/SimpleConsumerPerformance.scala modified , text changed
infrastructure at apache.org
 ViewVC Help
Powered by ViewVC 1.1.26