/[Apache-SVN]

Revision 1395729

Jump to revision:
Author:	jkreps
Date:	Mon Oct 8 19:13:24 2012 UTC (12 years, 1 month ago)
Changed paths:	72
Log Message:	KAFKA-506 Move to logical offsets. Reviewed by Jun and Neha.

Changed paths

Path	Details
incubator/kafka/branches/0.8/core/src/main/scala/kafka/Kafka.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchResponse.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/ProducerRequest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/ProducerResponse.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/cluster/Partition.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/ErrorMapping.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/InvalidTopicException.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/MessageSizeTooLargeException.scala	added
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/ConsumerIterator.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/FetchedDataChunk.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/PartitionTopicInfo.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/storage/	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/Implicits.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/TopicMetadata.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/TopicMetadataRequest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/message/ByteBufferMessageSet.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/log/FileMessageSet.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/log/Log.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/log/LogManager.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/log/LogSegment.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/log/OffsetIndex.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/log/OffsetPosition.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/log/SegmentList.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/ByteBufferMessageSet.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/CompressionFactory.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/CompressionUtils.scala	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/FileMessageSet.scala	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/Message.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/MessageAndOffset.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/MessageSet.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ConsoleProducer.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/AbstractFetcherThread.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/KafkaConfig.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaServer.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaFetcherThread.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/main/scala/kafka/utils/ZkUtils.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/other/kafka/TestLogPerformance.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/api/	added
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/api/RequestResponseSerializationTest.scala	added
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/FetcherTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/LazyInitProducerTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/LogCorruptionTest.scala	deleted
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/javaapi/message/ByteBufferMessageSetTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/FileMessageSetTest.scala	added
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/LogManagerTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/LogOffsetTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/LogSegmentTest.scala	added
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/LogTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/OffsetIndexTest.scala	added
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/message/BaseMessageSetTestCases.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/message/ByteBufferMessageSetTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/message/CompressionUtilsTest.scala	deleted
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/message/FileMessageSetTest.scala	deleted
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala	added
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/message/MessageTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/metrics/KafkaTimerTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/network/RpcDataSerializationTest.scala	deleted
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/producer/ProducerTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/producer/SyncProducerTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/utils/TestUtils.scala	modified , text changed
incubator/kafka/branches/0.8/perf/src/main/scala/kafka/perf/ConsumerPerformance.scala	modified , text changed

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26